Tablestore:検索インデックスを使用した Lastpoint データのクエリ

検索インデックスの作成

検索できるのは、検索インデックススキーマに含まれるフィールドのみです。Lastpoint インデックスの _tags フィールドは文字列配列であり、キーワード配列としてマッピングする必要があります。その他のデータフィールドは、対応する型にマッピングします。

次の例では、example_lastpoint_index に example_search_index を作成し、_tags、speed、status フィールドをインデックス化します。

List<FieldSchema> fieldSchemas = Arrays.asList(
        new FieldSchema("_tags", FieldType.KEYWORD)
                .setIndex(true).setIsArray(true),
        new FieldSchema("speed", FieldType.DOUBLE)
                .setIndex(true).setEnableSortAndAgg(true),
        new FieldSchema("status", FieldType.KEYWORD)
                .setIndex(true).setEnableSortAndAgg(true));

IndexSchema indexSchema = new IndexSchema();
indexSchema.setFieldSchemas(fieldSchemas);

CreateSearchIndexRequest request = new CreateSearchIndexRequest();
request.setTableName("example_lastpoint_index");
request.setIndexName("example_search_index");
request.setIndexSchema(indexSchema);

client.createSearchIndex(request);

最新データのクエリ

検索インデックスの作成は非同期です。インデックスステータスが RUNNING に変わり、データ同期フェーズが INCR に変わった後にクエリを実行します。

次の例では、範囲クエリを使用して speed が 20.0 より大きい Lastpoint の行を取得します。このクエリは、一致する行の総数とすべての列を返します。

RangeQuery rangeQuery = new RangeQuery();
rangeQuery.setFieldName("speed");
rangeQuery.greaterThan(ColumnValue.fromDouble(20.0));

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(rangeQuery);
searchQuery.setGetTotalCount(true);

SearchRequest request = new SearchRequest(
        "example_lastpoint_index",
        "example_search_index",
        searchQuery);
SearchRequest.ColumnsToGet columnsToGet =
        new SearchRequest.ColumnsToGet();
columnsToGet.setReturnAll(true);
request.setColumnsToGet(columnsToGet);

SearchResponse response = client.search(request);
System.out.println(response.getTotalCount());
response.getRows().forEach(System.out::println);

検索インデックス作成リクエスト

CreateSearchIndexRequest には、次のパラメーターが含まれます。

インデックスフィールド

indexSchema.fieldSchemas[] の各要素は FieldSchema 型です。例のフィールドは、次のパラメーターで設定します。

検索リクエスト

SearchRequest には、次のパラメーターが含まれます。