Java SDK for Tablestore を使用して collapse (distinct) 機能を実装する - Tablestore

クエリ結果に特定の種類のデータが大量に含まれている場合、collapse (個別) 機能を使用して、特定の列に基づいて結果セットを折りたたむことができます。特定の種類のデータは、結果の種類の多様性を確保するために、返された結果に一度だけ表示されます。

前提条件

OTSClient インスタンスが初期化されていること。詳細については、OTSClient インスタンスの初期化を参照してください。
データテーブルが作成され、データがデータテーブルに書き込まれていること。詳細については、データテーブルの作成およびデータの書き込みを参照してください。
データテーブルの検索インデックスが作成されていること。詳細については、検索インデックスの作成を参照してください。

使用上の注意

collapse (個別) 機能を使用する場合、offset パラメーターと limit パラメーターを指定することによってのみページネーションを実行できます。
結果セットを集計し、同時に折りたたむ場合、結果セットは折りたたむ前に集計されます。
クエリの結果を折りたたむ場合、返される結果の総数は、offset パラメーターと limit パラメーターの値の合計によって決まります。最大 100,000 件の結果を返すことができます。
レスポンスの行の総数は、collapse (個別) 機能を使用する前にクエリ条件を満たす行の数を示します。結果セットが折りたたまれた後、個別の値の総数をクエリすることはできません。

パラメーター

パラメーター	説明
query	クエリタイプ。このパラメーターは任意のクエリタイプに設定できます。
collapse	fieldName フィールドで指定された列に基づいて結果セットを折りたたみます。 fieldName: 結果セットの折りたたみの基準となる列の名前。値が INTEGER、FLOATING-POINT、または KEYWORD タイプの列のみがサポートされています。
offset	現在のクエリが開始される位置。
limit	現在のクエリで返される最大行数。特定のデータなしでクエリ条件を満たす行数のみをクエリするには、limit パラメーターを 0 に設定します。
getTotalCount	クエリ条件を満たす行の総数を返すかどうかを指定します。このパラメーターのデフォルト値は false で、クエリ条件を満たす行の総数は返されません。このパラメーターを true に設定すると、クエリのパフォーマンスが低下します。
tableName	データテーブルの名前。
indexName	検索インデックスの名前。
columnsToGet	クエリ条件を満たす各行のすべての列を返すかどうかを指定します。このパラメーターには、returnAll フィールドと columns フィールドを指定できます。 returnAll フィールドのデフォルト値は false で、すべての列が返されるわけではないことを指定します。この場合、columns フィールドを使用して、返したい列を指定できます。返したい列を指定しない場合は、主キー列のみが返されます。 returnAll フィールドを true に設定すると、すべての列が返されます。

例

次のサンプルコードは、user_id 列の値が "00002" と一致する行をクエリし、product_name 列の値に基づいて結果セットを折りたたむ方法の例を示しています。

private static void UseCollapse(SyncClient client){
    SearchQuery searchQuery = new SearchQuery(); // クエリ条件を指定します。
    MatchQuery matchQuery = new MatchQuery();
    matchQuery.setFieldName("user_id");
    matchQuery.setText("00002");

    searchQuery.setQuery(matchQuery);
    Collapse collapse = new Collapse("product_name"); // product_name 列に基づいて結果セットを折りたたみます。
    searchQuery.setCollapse(collapse);

    //searchQuery.setOffset(1000);// 現在のクエリが開始される位置。
    searchQuery.setLimit(20);
    //searchQuery.setGetTotalCount(true);// GetTotalCount パラメーターを true に設定して、クエリ条件を満たす行の総数を返します。

    SearchRequest searchRequest = new SearchRequest("<TABLE_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);// データテーブルの名前と検索インデックスの名前を指定します。    
    // columnsToGet パラメーターを使用して、返したい列を指定するか、すべての列を返すように指定できます。このパラメーターを指定しない場合は、主キー列のみが返されます。
    //SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
    //columnsToGet.setReturnAll(true); // ReturnAll パラメーターを true に設定して、すべての列を返します。
    //columnsToGet.setColumns(Arrays.asList("ColName1","ColName2")); // 返したい列を指定します。
    //searchRequest.setColumnsToGet(columnsToGet);

    SearchResponse response = client.search(searchRequest);  
    //System.out.println(response.getTotalCount());    
    //System.out.println(response.getRows().size()); // product_name 列に基づいて返される行の数を表示します。
    System.out.println(response.getRows()); // product_name 列に基づいて返される製品名を表示します。
}

FAQ

参考資料

検索インデックスを使用してデータをクエリする場合、次のクエリメソッドを使用できます。用語クエリ、複数用語クエリ、すべて一致クエリ、一致クエリ、一致フレーズクエリ、プレフィックスクエリ、範囲クエリ、ワイルドカードクエリ、地理クエリ、KNN ベクタークエリ、ブールクエリ、ネストクエリ、存在クエリ。検索インデックスを作成した後、検索インデックスによって提供されるクエリメソッドを使用して、ビジネス要件に基づいて複数のディメンションからデータをクエリできます。
ソート機能とページング機能を使用して、クエリ条件を満たす行をソートまたはページングできます。詳細については、ソートとページングの実行を参照してください。
collapse (個別) 機能を使用して、特定の列に基づいて結果セットを折りたたむことができます。このようにして、指定されたタイプのデータはクエリ結果に一度だけ表示されます。詳細については、Collapse (個別) を参照してください。
テーブル内のデータを分析する場合、Search 操作を呼び出して集計機能を使用するか、SQL クエリ機能を使用できます。たとえば、最大値と最小値、値の合計、行数をクエリできます。詳細については、集計および SQL クエリを参照してください。
行をソートする必要なく、クエリ条件を満たすすべての行を取得する場合、ParallelScan 操作と ComputeSplits 操作を呼び出して並列スキャン機能を使用できます。詳細については、並列スキャンを参照してください。