Tablestore:集約

フィールド内の最小値を返します。SQL の MIN 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Date タイプのみサポートされています。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 商品テーブルには各商品の価格が記録されています。浙江省で製造された商品の最低価格をクエリします。
   * SQL ステートメント: SELECT min(column_price) FROM product where place_of_production="Zhejiang".
   */
  public void min(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.term("place_of_production", "Zhejiang"))
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.min("min_agg_1", "column_price").missing(100))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsMinAggregationResult("min_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          TermQuery query = new TermQuery();
          query.setTerm(ColumnValue.fromString("Zhejiang"));
          query.setFieldName("place_of_production");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.term("place_of_production", "Zhejiang").build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          MinAggregation aggregation = new MinAggregation();
          aggregation.setAggName("min_agg_1");
          aggregation.setFieldName("column_price");
          aggregation.setMissing(ColumnValue.fromLong(100));
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // MinAggregation aggregation2 = AggregationBuilders.min("min_agg_1", "column_price").missing(100).build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsMinAggregationResult("min_agg_1").getValue());
      }
  }

フィールドの最大値を返します。SQL の max 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Date タイプのみサポートされています。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 商品テーブルには各商品の価格が記録されています。浙江省で製造された商品の最高価格をクエリします。
   * SQL ステートメント: SELECT max(column_price) FROM product where place_of_production="Zhejiang".
   */
  public void max(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.term("place_of_production", "Zhejiang"))
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.max("max_agg_1", "column_price").missing(0))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsMaxAggregationResult("max_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          TermQuery query = new TermQuery();
          query.setTerm(ColumnValue.fromString("Zhejiang"));
          query.setFieldName("place_of_production");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.term("place_of_production", "Zhejiang").build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          MaxAggregation aggregation = new MaxAggregation();
          aggregation.setAggName("max_agg_1");
          aggregation.setFieldName("column_price");
          aggregation.setMissing(ColumnValue.fromLong(100));
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // MaxAggregation aggregation2 = AggregationBuilders.max("max_agg_1", "column_price").missing(100).build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsMaxAggregationResult("max_agg_1").getValue());
      }
  }

数値フィールドの値の合計を返します。SQL の sum 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long および Double タイプのみサポートされています。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 各プロダクトの価格はプロダクトテーブルに記載されています。浙江省で生産されたプロダクトの最大価格をクエリします。
   * SQL ステートメント: SELECT sum(column_price) FROM product where place_of_production="Zhejiang".
   */
  public void sum(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.term("place_of_production", "Zhejiang"))
                                  .limit(0) //特定のデータではなく集約結果のみを取得したい場合は、クエリパフォーマンスを向上させるために limit を 0 に設定します。
                                  .addAggregation(AggregationBuilders.sum("sum_agg_1", "column_number").missing(10))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsSumAggregationResult("sum_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          TermQuery query = new TermQuery();
          query.setTerm(ColumnValue.fromString("Zhejiang"));
          query.setFieldName("place_of_production");
          //次のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.term("place_of_production", "Zhejiang").build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          SumAggregation aggregation = new SumAggregation();
          aggregation.setAggName("sum_agg_1");
          aggregation.setFieldName("column_number");
          aggregation.setMissing(ColumnValue.fromLong(100));
          //次のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // SumAggregation aggregation2 = AggregationBuilders.sum("sum_agg_1", "column_number").missing(10).build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsSumAggregationResult("sum_agg_1").getValue());
      }
  }

数値フィールドの平均値を計算します。SQL の avg 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Date タイプのみサポートされています。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 商品テーブルには各商品の販売数量が記録されています。浙江省で製造された商品の平均価格をクエリします。
   * SQL ステートメント: SELECT avg(column_price) FROM product where place_of_production="Zhejiang".
   */
  public void avg(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.term("place_of_production", "Zhejiang"))
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.avg("avg_agg_1", "column_price"))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsAvgAggregationResult("avg_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          TermQuery query = new TermQuery();
          query.setTerm(ColumnValue.fromString("Zhejiang"));
          query.setFieldName("place_of_production");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.term("place_of_production", "Zhejiang").build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          AvgAggregation aggregation = new AvgAggregation();
          aggregation.setAggName("avg_agg_1");
          aggregation.setFieldName("column_price");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // AvgAggregation aggregation2 = AggregationBuilders.avg("avg_agg_1", "column_price").build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsAvgAggregationResult("avg_agg_1").getValue());
      }
  }                    

指定されたフィールドの値の数、または多次元インデックス内の行の総数をカウントします。SQL の count 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Boolean、Keyword、Geo_point、Date タイプのみサポートされています。

• 例

  /**
   * 商店の罰則記録は商店テーブルに記録されています。浙江省に所在し、罰則記録が存在する商店の数をクエリできます。商店に罰則記録が存在しない場合、罰則記録に対応するフィールドもその商店には存在しません。
   * SQL ステートメント: SELECT count(column_history) FROM product where place_of_production="Zhejiang".
   */
  public void count(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.term("place_of_production", "Zhejiang"))
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.count("count_agg_1", "column_history"))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsCountAggregationResult("count_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          TermQuery query = new TermQuery();
          query.setTerm(ColumnValue.fromString("Zhejiang"));
          query.setFieldName("place_of_production");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.term("place_of_production", "Zhejiang").build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          CountAggregation aggregation = new CountAggregation();
          aggregation.setAggName("count_agg_1");
          aggregation.setFieldName("column_history");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // CountAggregation aggregation2 = AggregationBuilders.count("count_agg_1", "column_history").build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsCountAggregationResult("count_agg_1").getValue());
      }
  }

指定されたフィールドの個別値の数を返します。SQL の count(distinct) 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Boolean、Keyword、Geo_point、Date タイプのみサポートされています。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 商品が製造された都道府県の個別数をクエリします。
   * SQL ステートメント: SELECT count(distinct column_place) FROM product.
   */
  public void distinctCount(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.matchAll())
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.distinctCount("dis_count_agg_1", "column_place"))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsDistinctCountAggregationResult("dis_count_agg_1").getValue());
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          MatchAllQuery query = new MatchAllQuery();
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.matchAll().build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          DistinctCountAggregation aggregation = new DistinctCountAggregation();
          aggregation.setAggName("dis_count_agg_1");
          aggregation.setFieldName("column_place");
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // DistinctCountAggregation aggregation2 = AggregationBuilders.distinctCount("dis_count_agg_1", "column_place").build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          System.out.println(resp.getAggregationResults().getAsDistinctCountAggregationResult("dis_count_agg_1").getValue());
      }
  }

パーセンタイル統計を使用して、データセットのパーセンタイル分布を分析します。たとえば、日常的な運用管理 (O&M) 中に、P25、P50、P90、P99 などのパーセンタイルを確認することで、リクエスト遅延の分布を追跡できます。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Date タイプのみサポートされています。
  percentiles	p50、p90、p99 などのパーセンタイルです。1 つ以上のパーセンタイルを指定できます。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * パーセンタイルを使用して、システムに送信された各リクエストの応答時間の分布を分析します。
   */
  public void percentilesAgg(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("indexName")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.matchAll())
                                  .limit(0) //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addAggregation(AggregationBuilders.percentiles("percentilesAgg", "latency")
                                          .percentiles(Arrays.asList(25.0d, 50.0d, 99.0d))
                                          .missing(1.0))
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //結果を取得します。
          PercentilesAggregationResult percentilesAggregationResult = resp.getAggregationResults().getAsPercentilesAggregationResult("percentilesAgg");
          for (PercentilesAggregationItem item : percentilesAggregationResult.getPercentilesAggregationItems()) {
              System.out.println("key：" + item.getKey() + " value:" + item.getValue().asDouble());
          }
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          MatchAllQuery query = new MatchAllQuery();
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.matchAll().build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          PercentilesAggregation aggregation = new PercentilesAggregation();
          aggregation.setAggName("percentilesAgg");
          aggregation.setFieldName("latency");
          aggregation.setPercentiles(Arrays.asList(25.0d, 50.0d, 99.0d));
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // AggregationBuilders.percentiles("percentilesAgg", "latency").percentiles(Arrays.asList(25.0d, 50.0d, 99.0d)).missing(1.0).build();
          List<Aggregation> aggregationList = new ArrayList<Aggregation>();
          aggregationList.add(aggregation);
          searchQuery.setAggregationList(aggregationList);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //結果を取得します。
          PercentilesAggregationResult percentilesAggregationResult = resp.getAggregationResults().getAsPercentilesAggregationResult("percentilesAgg");
          for (PercentilesAggregationItem item : percentilesAggregationResult.getPercentilesAggregationItems()) {
              System.out.println("key：" + item.getKey() + " value:" + item.getValue().asDouble());
          }
      }
  }

指定されたフィールドの値に基づいてクエリ結果をグループ化します。同じフィールド値を持つ行が 1 つのグループを形成します。この操作は、各グループの値とその行数を返します。

• パラメーター

  パラメーター	説明
  groupByName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long、Double、Boolean、Keyword、Date タイプのみサポートされています。
  groupBySorter	グループのソートルールです。デフォルトでは、グループ内のアイテム数に基づいて降順でソートされます。複数のソートルールを設定した場合、ルールを設定した順序に基づいてグループがソートされます。次のソートルールがサポートされています。 groupKeySortInAsc: 値をアルファベット順にソートします。 groupKeySortInDesc: 値をアルファベット逆順にソートします。 rowCountSortInAsc: 行数を昇順にソートします。 rowCountSortInDesc (デフォルト): 行数を降順にソートします。 subAggSortInAsc: サブ集約結果から取得した値を昇順にソートします。 subAggSortInDesc: サブ集約結果から取得した値を降順にソートします。
  size	返すグループの数です。デフォルト値は 10、最大値は 2000 です。
  subAggregations	各グループ内のデータに対して実行できるサブ集約操作です。たとえば、最大値、合計、平均値の計算などです。
  subGroupBys	各親グループ内のデータに対して実行できるサブグループ化操作で、データをさらにグループ化します。

• 例

  単一フィールドによるグループ化

  /**
   * 各カテゴリの商品数、および商品価格の最大値と最小値をクエリします。
   * 返される結果の例: 果物: 5。最高価格は 2 米ドル、最低価格は 0.5 米ドル。日用品: 10。最高価格は 13 米ドル、最低価格は 0.1 米ドル。電子機器: 3。最高価格は 1,160 米ドル、最低価格は 310 米ドル。その他商品: 15。最高価格は 130 米ドル、最低価格は 11 米ドル。
   */
  public void groupByField(SyncClient client) {
      //ビルダーを使用してクエリ文を作成します。
      {
          SearchRequest searchRequest = SearchRequest.newBuilder()
                  .tableName("<TABLE_NAME>")
                  .indexName("<SEARCH_INDEX_NAME>")
                  .searchQuery(
                          SearchQuery.newBuilder()
                                  .query(QueryBuilders.matchAll())
                                  .limit(0)  //集約結果のみを取得し、具体的なデータを取得しない場合は、limit を 0 に設定してクエリパフォーマンスを向上させます。
                                  .addGroupBy(GroupByBuilders
                                          .groupByField("name1", "column_type")
                                          .addSubAggregation(AggregationBuilders.min("subName1", "column_price"))
                                          .addSubAggregation(AggregationBuilders.max("subName2", "column_price"))
                                  )
                                  .build())
                  .build();
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          for (GroupByFieldResultItem item : resp.getGroupByResults().getAsGroupByFieldResult("name1").getGroupByFieldResultItems()) {
              //値を表示します。
              System.out.println(item.getKey());
              //行数を表示します。
              System.out.println(item.getRowCount());
              //最低価格を表示します。
              System.out.println(item.getSubAggregationResults().getAsMinAggregationResult("subName1").getValue());
              //最高価格を表示します。
              System.out.println(item.getSubAggregationResults().getAsMaxAggregationResult("subName2").getValue());
          }
      }
  
      //ビルダーを使用せずにクエリ文を作成します。
      {
          SearchRequest searchRequest = new SearchRequest();
          searchRequest.setTableName("<TABLE_NAME>");
          searchRequest.setIndexName("<SEARCH_INDEX_NAME>");
  
          SearchQuery searchQuery = new SearchQuery();
          MatchAllQuery query = new MatchAllQuery();
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、TermQuery を使用してクエリ文を作成する方法と同じ効果があります。
          // Query query2 = QueryBuilders.matchAll().build();
  
          searchQuery.setQuery(query);
          searchQuery.setLimit(0);
  
          GroupByField groupByField = new GroupByField();
          groupByField.setGroupByName("name1");
          groupByField.setFieldName("column_type");
          //サブ集約操作を設定します。
          MinAggregation minAggregation = AggregationBuilders.min("subName1", "column_price").build();
          MaxAggregation maxAggregation = AggregationBuilders.max("subName2", "column_price").build();
          groupByField.setSubAggregations(Arrays.asList(minAggregation, maxAggregation));
  
          //以下のコメントでは、ビルダーを使用してクエリ文を作成しています。ビルダーを使用してクエリ文を作成する方法は、aggregation を使用してクエリ文を作成する方法と同じ効果があります。
          // GroupByBuilders.groupByField("name1", "column_type")
          //        .addSubAggregation(AggregationBuilders.min("subName1", "column_price"))
          //        .addSubAggregation(AggregationBuilders.max("subName2", "column_price").build());
          List<GroupBy> groupByList = new ArrayList<GroupBy>();
          groupByList.add(groupByField);
          searchQuery.setGroupByList(groupByList);
          searchRequest.setSearchQuery(searchQuery);
  
          //クエリ文を実行します。
          SearchResponse resp = client.search(searchRequest);
          //集約結果を取得します。
          for (GroupByFieldResultItem item : resp.getGroupByResults().getAsGroupByFieldResult("name1").getGroupByFieldResultItems()) {
              //値を表示します。
              System.out.println(item.getKey());
              //行数を表示します。
              System.out.println(item.getRowCount());
              //最低価格を表示します。
              System.out.println(item.getSubAggregationResults().getAsMinAggregationResult("subName1").getValue());
              //最高価格を表示します。
              System.out.println(item.getSubAggregationResults().getAsMaxAggregationResult("subName2").getValue());
          }
      }
  }

  ネストモードでの複数フィールドによるグループ化

  /**
   * 複数フィールドによるグループ化クエリ結果のネストモードでの例。
   * 多次元インデックスで、SQL ステートメントの複数 GROUP BY フィールドと同等の効果を得るために、ネストモードで 2 つの groupBy フィールドを使用します。
   * SQL ステートメント: select a,d, sum(b),sum(c) from user group by a,d.
   */
  public void GroupByMultiField(SyncClient client) {
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .returnAllColumns(true)   //returnAllColumns を false に設定し、addColumesToGet に値を指定すると、クエリパフォーマンスが向上します。
          //.addColumnsToGet("col_1","col_2")
          .searchQuery(SearchQuery.newBuilder()
              .query(QueryBuilders.matchAll())   //クエリ条件を指定します。クエリ条件は SQL の WHERE 句と同様に使用できます。ネストクエリを実行するには QueryBuilders.bool() を使用します。
              .addGroupBy(
                  GroupByBuilders
                      .groupByField("unique name_1", "field_a")
                      .size(20)
                      .addSubGroupBy(
                          GroupByBuilders
                              .groupByField("unique name_2", "field_d")
                              .size(20)
                              .addSubAggregation(AggregationBuilders.sum("unique name_3", "field_b"))
                              .addSubAggregation(AggregationBuilders.sum("unique name_4", "field_c"))
                      )
              )
              .build())
          .build();
      SearchResponse response = client.search(searchRequest);
      //指定された条件を満たす行をクエリします。
      List<Row> rows = response.getRows();
      //集約結果を取得します。
      GroupByFieldResult groupByFieldResult1 = response.getGroupByResults().getAsGroupByFieldResult("unique name_1");
      for (GroupByFieldResultItem resultItem : groupByFieldResult1.getGroupByFieldResultItems()) {
          System.out.println("field_a key:" + resultItem.getKey() + " Count:" + resultItem.getRowCount());
          //サブ集約結果を取得します。
          GroupByFieldResult subGroupByResult = resultItem.getSubGroupByResults().getAsGroupByFieldResult("unique name_2");
          for (GroupByFieldResultItem item : subGroupByResult.getGroupByFieldResultItems()) {
              System.out.println("field_a " + resultItem.getKey() + " field_d key:" + item.getKey() + " Count: " + item.getRowCount());
              double sumOf_field_b = item.getSubAggregationResults().getAsSumAggregationResult("unique name_3").getValue();
              double sumOf_field_c = item.getSubAggregationResults().getAsSumAggregationResult("unique name_4").getValue();
              System.out.println("sumOf_field_b:" + sumOf_field_b);
              System.out.println("sumOf_field_c:" + sumOf_field_c);
          }
      }
  }

  集約のグループソートの設定

  /**
   * 集約のソートルールを設定する例。
   * 方法: GroupBySorter を指定してソートルールを設定します。複数のソートルールを設定した場合、ルールを設定した順序に基づいてグループがソートされます。GroupBySorter は昇順または降順でのソートをサポートしています。
   * デフォルトでは、グループは行数の降順 (GroupBySorter.rowCountSortInDesc()) でソートされます。
   */
  public void groupByFieldWithSort(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .searchQuery(
              SearchQuery.newBuilder()
                  .query(QueryBuilders.matchAll())
                  .limit(0)
                  .addGroupBy(GroupByBuilders
                      .groupByField("name1", "column_type")
                      //.addGroupBySorter(GroupBySorter.subAggSortInAsc("subName1")) //サブ集約結果から取得した値に基づいてグループを昇順にソートします。
                      .addGroupBySorter(GroupBySorter.groupKeySortInAsc())           //集約結果から取得した値に基づいてグループを昇順にソートします。
                      //.addGroupBySorter(GroupBySorter.rowCountSortInDesc())        //各グループの集約結果から取得した行数に基づいてグループを降順にソートします。
                      .size(20)
                      .addSubAggregation(AggregationBuilders.min("subName1", "column_price"))
                      .addSubAggregation(AggregationBuilders.max("subName2", "column_price"))
                  )
                  .build())
          .build();
      //クエリ文を実行します。
      SearchResponse resp = client.search(searchRequest);
  }

グループ化集約はネストをサポートしており、グループ内にサブ集約を追加できます。

• 適用シナリオ

  • マルチレベルグループ化 (GroupBy + SubGroupBy)

    第 1 レベルでデータをグループ化した後、第 2 レベルでグループ化を実行します。たとえば、まず都道府県でデータをグループ化し、次に市区町村でグループ化して、各都道府県の市区町村ごとのデータを取得します。

  • グループ化後の集約 (GroupBy + SubAggregation)

    第 1 レベルでデータをグループ化した後、各グループ内のデータに対して集約操作 (最大値や平均値の計算など) を実行します。たとえば、都道府県でデータをグループ化した後、各都道府県グループの特定のメトリックの最大値を取得します。

• 例

  次の例は、都道府県と市区町村でネストされたグループ化を実行し、各都道府県の注文総数と各市区町村の注文総数および最大注文金額を計算する方法を示しています。

  public static void subGroupBy(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
              .tableName("<TABLE_NAME>")
              .indexName("<SEARCH_INDEX_NAME>")
              .returnAllColumns(true)
              .searchQuery(SearchQuery.newBuilder()
                      .query(QueryBuilders.matchAll()).limit(20)
                      //第 1 レベルのグループ化: 都道府県でグループ化し、各都道府県の注文 ID 数 (注文総数) をカウントします。
                      //第 2 レベルのグループ化: 市区町村でグループ化し、各市区町村の注文 ID 数 (注文総数) をカウントし、各市区町村の最大注文金額を計算します。
                      .addGroupBy(GroupByBuilders.groupByField("provinceName", "province")
                              .addSubAggregation(AggregationBuilders.count("provinceOrderCounts", "order_id"))
                              .addGroupBySorter(GroupBySorter.rowCountSortInDesc())
                              .addSubGroupBy(GroupByBuilders.groupByField("cityName", "city")
                                      .addSubAggregation(AggregationBuilders.count("cityOrderCounts", "order_id"))
                                      .addSubAggregation(AggregationBuilders.max("cityMaxAmount", "order_amount"))
                                      .addGroupBySorter(GroupBySorter.subAggSortInDesc("cityMaxAmount"))))
                      .build())
              .build();
      
      //クエリ文を実行します。
      SearchResponse resp = client.search(searchRequest);
      
      //第 1 レベルのグループ化結果を取得します (各都道府県の注文総数)
      GroupByFieldResult results = resp.getGroupByResults().getAsGroupByFieldResult("provinceName");
      for (GroupByFieldResultItem item : results.getGroupByFieldResultItems()) {
          System.out.println("都道府県:" + item.getKey()
                  + "\t注文総数:" + item.getSubAggregationResults().getAsCountAggregationResult("provinceOrderCounts").getValue());
          
          //第 2 レベルのグループ化結果を取得します (各市区町村の注文総数および最大注文金額)
          GroupByFieldResult subResults = item.getSubGroupByResults().getAsGroupByFieldResult("cityName");
          for (GroupByFieldResultItem subItem : subResults.getGroupByFieldResultItems()) {
              System.out.println("\t(市区町村)" + subItem.getKey()
                      + "\t注文総数:" + subItem.getSubAggregationResults().getAsCountAggregationResult("cityOrderCounts").getValue()
                      + "\t最大注文金額:" + subItem.getSubAggregationResults().getAsMaxAggregationResult("cityMaxAmount").getValue());
          }
      }
  }

フィールドの値に基づいてクエリ結果をカスタム範囲にグループ化し、各範囲のカウントを返します。

• パラメーター

  パラメーター	説明
  groupByName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long および Double タイプのみサポートされています。
  range[double_from, double_to)	グループ化のための値範囲です。 最小値を指定するには double_from を Double.MIN_VALUE に設定し、最大値を指定するには double_to を Double.MAX_VALUE に設定します。
  subAggregation および subGroupBy	サブ集約操作です。グループ化結果に基づいてサブ集約操作を実行します。 たとえば、販売数量と都道府県でクエリ結果をグループ化した後、指定された範囲内で販売数量の割合が最も大きい都道府県を取得するには、GroupByRange 内で GroupByField を指定する必要があります。

• 例

  /**
   * 販売数量を範囲 [0, 1000)、[1000, 5000)、[5000, Double.MAX_VALUE) に基づいてグループ化し、各範囲の販売数量を取得します。
   */
  public void groupByRange(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .searchQuery(
              SearchQuery.newBuilder()
                  .query(QueryBuilders.matchAll())
                  .limit(0)
                  .addGroupBy(GroupByBuilders
                      .groupByRange("name1", "column_number")
                      .addRange(0, 1000)
                      .addRange(1000, 5000)
                      .addRange(5000, Double.MAX_VALUE)
                  )
                  .build())
          .build();
      //クエリ文を実行します。
      SearchResponse resp = client.search(searchRequest);
      //集約結果を取得します。
      for (GroupByRangeResultItem item : resp.getGroupByResults().getAsGroupByRangeResult("name1").getGroupByRangeResultItems()) {
  
          //行数を表示します。
          System.out.println(item.getRowCount());
      }
  }

原点からの距離に基づいてクエリ結果をグループ化します。この操作は、指定された距離範囲内のアイテムを同じグループに配置し、各範囲のカウントを返します。

• パラメーター

  パラメーター	説明
  groupByName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Geo_point タイプのみサポートされています。
  origin(double lat, double lon)	中心点の経度と緯度です。 double lat は中心点の緯度を指定します。double lon は中心点の経度を指定します。
  range[double_from, double_to)	グループ化に使用する距離範囲です。単位はメートルです。 最小値を指定するには double_from を Double.MIN_VALUE に設定し、最大値を指定するには double_to を Double.MAX_VALUE に設定します。
  subAggregation および subGroupBy	サブ集約操作です。グループ化結果に基づいてサブ集約操作を実行します。

• 例

  /**
   * ワンダープラザからの地理的位置に基づいてユーザーをグループ化し、各距離範囲のユーザー数を取得します。距離範囲は [0, 1000)、[1000, 5000)、[5000, Double.MAX_VALUE) です。単位はメートルです。
   */
  public void groupByGeoDistance(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .searchQuery(
              SearchQuery.newBuilder()
                  .query(QueryBuilders.matchAll())
                  .limit(0)
                  .addGroupBy(GroupByBuilders
                      .groupByGeoDistance("name1", "column_geo_point")
                      .origin(3.1, 6.5)
                      .addRange(0, 1000)
                      .addRange(1000, 5000)
                      .addRange(5000, Double.MAX_VALUE)
                  )
                  .build())
          .build();
      //クエリ文を実行します。
      SearchResponse resp = client.search(searchRequest);
      //集約結果を取得します。
      for (GroupByGeoDistanceResultItem item : resp.getGroupByResults().getAsGroupByGeoDistanceResult("name1").getGroupByGeoDistanceResultItems()) {
         //行数を表示します。
          System.out.println(item.getRowCount());
      }
  }

指定されたフィルターに基づいてクエリ結果をグループ化します。この集約は、各フィルターに一致するドキュメントの数を返します。結果は、フィルターを追加したのと同じ順序で返されます。

• パラメーター

  パラメーター	説明
  groupByName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  filter	クエリに使用できるフィルターです。結果は、フィルターを指定した順序で返されます。
  subAggregation および subGroupBy	サブ集約操作です。グループ化結果に基づいてサブ集約操作を実行します。

• 例

  /**
   * 次のフィルターを指定して、各フィルターに一致するアイテムの数を取得します: 販売数量が 100 を超える、産地が浙江省、説明に杭州が含まれる。
   */
  public void groupByFilter(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .searchQuery(
              SearchQuery.newBuilder()
                  .query(QueryBuilders.matchAll())
                  .limit(0) 
                  .addGroupBy(GroupByBuilders
                      .groupByFilter("name1")
                      .addFilter(QueryBuilders.range("number").greaterThanOrEqual(100))
                      .addFilter(QueryBuilders.term("place","Zhejiang"))
                      .addFilter(QueryBuilders.match("text","Hangzhou"))
                  )
                  .build())
          .build();
      //クエリ文を実行します。
      SearchResponse resp = client.search(searchRequest);
      //フィルターの順序に基づいて集約結果を取得します。
      for (GroupByFilterResultItem item : resp.getGroupByResults().getAsGroupByFilterResult("name1").getGroupByFilterResultItems()) {
          //行数を表示します。
          System.out.println(item.getRowCount());
      }
  }

指定されたデータ間隔に基づいてクエリ結果をグループ化します。同じ間隔内にフィールド値が存在する行は同じグループに配置されます。この操作は、各グループの開始値と対応する行数を返します。

• パラメーター

  パラメーター	説明
  groupByName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  fieldName	集約操作を実行するフィールドの名前です。Long および Double タイプのみサポートされています。
  interval	集約結果を取得するために使用するデータ間隔です。
  fieldRange[min,max]	interval パラメーターとともに使用してグループ数を制限する範囲です。(fieldRange.max-fieldRange.min)/interval 式で決定されるグループ数は 2,000 を超えてはなりません。
  minDocCount	最小行数です。グループ内の行数が最小行数未満の場合、そのグループの集約結果は返されません。
  missing	集約操作を実行するフィールドのデフォルト値で、フィールド値が空の行に適用されます。 missing パラメーターの値を指定しない場合、その行は無視されます。 missing パラメーターの値を指定した場合、そのパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 年齢層別のユーザー分布の統計情報を収集します。
   */
  public static void groupByHistogram(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<TABLE_NAME>")
          .indexName("<SEARCH_INDEX_NAME>")
          .searchQuery(
              SearchQuery.newBuilder()
                  .addGroupBy(GroupByBuilders
                      .groupByHistogram("groupByHistogram", "age")
                      .interval(10)
                      .minDocCount(0L)
                      .addFieldRange(0, 99))
                  .build())
          .build();
      //クエリ文を実行します。
      SearchResponse resp = ots.search(searchRequest);
      //集約操作が実行されたときに返される結果を取得します。
      GroupByHistogramResult results = resp.getGroupByResults().getAsGroupByHistogramResult("groupByHistogram");
      for (GroupByHistogramItem item : results.getGroupByHistogramItems()) {
          System.out.println("key：" + item.getKey().asLong() + " value:" + item.getValue());
      }
  }

クエリ結果をグループ化した後、トップ行集約を使用して各グループから選択された行を取得します。この機能は、MySQL の ANY_VALUE(field) 関数と同様です。

• パラメーター

  パラメーター	説明
  aggregationName	集約操作の一意の名前です。この名前に基づいて特定の集約操作の結果をクエリします。
  limit	各グループで返される行の最大数です。デフォルトでは、1 行のデータのみが返されます。
  sort	グループ内のデータをソートするために使用するソート方法です。
  columnsToGet	返却するフィールド。検索インデックス内のフィールドのみがサポートされています。配列、日付、ジオポイント、およびネストされたフィールドはサポートされていません。 このパラメーターの値は、SearchRequest の columnsToGet パラメーターの値と同じです。SearchRequest の columnsToGet パラメーターにのみ値を指定する必要があります。

• 例

  /**
   * 学校の活動申請フォームには、学生の氏名、クラス、担任教師、クラス委員長などの情報を指定できるフィールドが含まれています。クラスで学生をグループ化して、申請統計と各クラスのプロパティ情報を表示します。
   * SQL ステートメント: select className, teacher, monitor, COUNT(*) as number from table GROUP BY className.
   */
  public void testTopRows(SyncClient client) {
      SearchRequest searchRequest = SearchRequest.newBuilder()
              .indexName("<SEARCH_INDEX_NAME>")
              .tableName("<TABLE_NAME>")
              .searchQuery(
                      SearchQuery.newBuilder()
                              .query(QueryBuilders.matchAll())
                              .limit(0) 
                              .addGroupBy(GroupByBuilders.groupByField("groupName", "className")
                                      .size(5)  //返すグループ数を指定します。「多次元インデックスの制限事項」トピックの「GroupByField で返されるグループ数」の説明で、返すグループ数に指定できる最大値をご確認ください。
                                      .addSubAggregation(AggregationBuilders.topRows("topRowsName")
                                              .limit(1)
                                              .sort(new Sort(Arrays.asList(new FieldSort("teacher", SortOrder.DESC)))) //教師を降順で行をソートします。
                                      )
                              )
                              .build())
              .addColumnsToGet(Arrays.asList("teacher", "monitor"))
              .build();
      SearchResponse resp = client.search(searchRequest);
      List<GroupByFieldResultItem> items = resp.getGroupByResults().getAsGroupByFieldResult("groupName").getGroupByFieldResultItems();
      for (GroupByFieldResultItem item : items) {
          String className = item.getKey();
          long number = item.getRowCount();
          List<Row> topRows = item.getSubAggregationResults().getAsTopRowsAggregationResult("topRowsName").getRows();
          Row row = topRows.get(0);
          String teacher = row.getLatestColumn("teacher").getValue().asString();
          String monitor = row.getLatestColumn("monitor").getValue().asString();
      }
  }

単一のクエリで複数の集約を組み合わせることができます。

public void multipleAggregation(SyncClient client) {
    //クエリ文を作成します。
    SearchRequest searchRequest = SearchRequest.newBuilder()
        .tableName("<TABLE_NAME>")
        .indexName("<SEARCH_INDEX_NAME>")
        .searchQuery(
            SearchQuery.newBuilder()
                .query(QueryBuilders.matchAll())
                .limit(0) 
                .addAggregation(AggregationBuilders.min("name1", "long"))
                .addAggregation(AggregationBuilders.sum("name2", "long"))
                .addAggregation(AggregationBuilders.distinctCount("name3", "long"))
                .build())
        .build();
    //クエリ文を実行します。
    SearchResponse resp = client.search(searchRequest);
    //集約操作の結果から最小値を取得します。
    System.out.println(resp.getAggregationResults().getAsMinAggregationResult("name1").getValue());
    //集約操作の結果から合計を取得します。
    System.out.println(resp.getAggregationResults().getAsSumAggregationResult("name2").getValue());
    //集約操作の結果から個別値の数を取得します。
    System.out.println(resp.getAggregationResults().getAsDistinctCountAggregationResult("name3").getValue());
}

public void multipleGroupBy(SyncClient client) {
    //クエリ文を作成します。
    SearchRequest searchRequest = SearchRequest.newBuilder()
        .tableName("<TABLE_NAME>")
        .indexName("<SEARCH_INDEX_NAME>")
        .searchQuery(
            SearchQuery.newBuilder()
                .query(QueryBuilders.matchAll())
                .limit(0)
                .addAggregation(AggregationBuilders.min("name1", "long"))
                .addAggregation(AggregationBuilders.sum("name2", "long"))
                .addAggregation(AggregationBuilders.distinctCount("name3", "long"))
                .addGroupBy(GroupByBuilders.groupByField("name4", "type"))
                .addGroupBy(GroupByBuilders.groupByRange("name5", "long").addRange(1, 15))
                .build())
        .build();
    //クエリ文を実行します。
    SearchResponse resp = client.search(searchRequest);
    //集約操作の結果から最小値を取得します。
    System.out.println(resp.getAggregationResults().getAsMinAggregationResult("name1").getValue());
    //集約操作の結果から合計を取得します。
    System.out.println(resp.getAggregationResults().getAsSumAggregationResult("name2").getValue());
    //集約操作の結果から個別値の数を取得します。
    System.out.println(resp.getAggregationResults().getAsDistinctCountAggregationResult("name3").getValue());
    //集約操作の結果から GroupByField の値を取得します。
    for (GroupByFieldResultItem item : resp.getGroupByResults().getAsGroupByFieldResult("name4").getGroupByFieldResultItems()) {
        //キーを表示します。
        System.out.println(item.getKey());
        //行数を表示します。
        System.out.println(item.getRowCount());
    }
    //集約操作の結果から GroupByRange の値を取得します。
    for (GroupByRangeResultItem item : resp.getGroupByResults().getAsGroupByRangeResult("name5").getGroupByRangeResultItems()) {
        //行数を表示します。
        System.out.println(item.getRowCount());
    }
}