Tablestore：檢索Lastpoint索引

1. 建立多元索引

以下樣本用於為Lastpoint索引建立一個多元索引。樣本情境及資料請參見附錄。

private static void createSearchIndex(SyncClient client) {
    CreateSearchIndexRequest createSearchIndexRequest = new CreateSearchIndexRequest();
    createSearchIndexRequest.setTableName("<LASTPOINT_INDEX_NAME>");
    createSearchIndexRequest.setIndexName("<SEARCH_INDEX_NAME>");
    IndexSchema indexSchema = new IndexSchema();
    indexSchema.setFieldSchemas(Arrays.asList(
            new FieldSchema("_#h", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_m_name", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_data_source", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_tags", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true).setIsArray(true),
            new FieldSchema("_time", FieldType.LONG).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("gps", FieldType.GEO_POINT).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("speed", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("status", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("total_mileage", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("remaining_mileage", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true)
    ));
    createSearchIndexRequest.setIndexSchema(indexSchema);
    client.createSearchIndex(createSearchIndexRequest);
}

2. 通過多元索引檢索資料

此處以範圍查詢為例介紹多元索引查詢功能的使用。

以下樣本用於通過多元索引檢索Lastpoint索引中speed值大於20.0的行資料。

private static void rangeQuery(SyncClient client) {
    SearchQuery searchQuery = new SearchQuery();
    RangeQuery rangeQuery = new RangeQuery(); //設定查詢類型為RangeQuery。
    rangeQuery.setFieldName("speed");  //設定要匹配的欄位。
    rangeQuery.greaterThan(ColumnValue.fromDouble(20.0));  //設定該欄位的範圍條件為大於20.0。
    searchQuery.setGetTotalCount(true);
    searchQuery.setQuery(rangeQuery);
    //設定按照speed列逆序排序。
    FieldSort fieldSort = new FieldSort("speed");
    fieldSort.setOrder(SortOrder.DESC);
    searchQuery.setSort(new Sort(Arrays.asList((Sort.Sorter)fieldSort)));
    searchQuery.setGetTotalCount(true); //設定返回匹配的總行數。

    SearchRequest searchRequest = new SearchRequest("<LASTPOINT_INDEX_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);
    //通過設定columnsToGet參數可以指定返回的列或返回所有列，如果不設定此參數，則預設只返回主鍵列。
    SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
    columnsToGet.setReturnAll(true); //設定為返回所有列。
    searchRequest.setColumnsToGet(columnsToGet);

    SearchResponse resp = client.search(searchRequest);
    System.out.println("TotalCount: " + resp.getTotalCount()); //列印匹配到的總行數，非返回行數。
    System.out.println("Row: " + resp.getRows());
}