Tablestore:Java SDK での検索インデックスを使用した Lastpoint インデックスデータの取得

1. 検索インデックスを作成する

次の例は、Lastpoint インデックスの検索インデックスを作成する方法を示しています。サンプルのシナリオとデータについては、「付録」をご参照ください。

private static void createSearchIndex(SyncClient client) {
    CreateSearchIndexRequest createSearchIndexRequest = new CreateSearchIndexRequest();
    createSearchIndexRequest.setTableName("");
    createSearchIndexRequest.setIndexName("");
    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. 検索インデックスを使用してデータを取得する

次の例は、検索インデックスの範囲クエリ機能の使用方法を示しています。

この例では、検索インデックスを使用して、速度値が 20.0 より大きい Lastpoint インデックスから行を取得する方法を示します。

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);
    // 速度列で降順にソート順を設定します。
    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("", "", 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());
}