Tablestore:集計

フィールドの最小値を返すために使用できる集計方法。このメソッドは、SQL の MIN 演算子と同様の方法で使用できます。

• パラメーター

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

• 例

  /**
   * 各製品の価格は product テーブルにリストされています。浙江省で生産された製品の最低価格を照会します。
   * SQL 文: SELECT min(column_price) FROM product where place_of_production="Zhejiang".
   */
  public void min(SyncClient client) {
      // builder を使用してクエリステートメントを作成します。
      {
          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());
      }
  
      // builder を使用せずにクエリステートメントを作成します。
      {
          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");
          // 次のコメントでは、 builder を使用してクエリステートメントを作成しています。 builder を使用してクエリステートメントを作成する方法は、 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));
          // 次のコメントでは、 builder を使用してクエリステートメントを作成しています。 builder を使用してクエリステートメントを作成する方法は、 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 パラメーターの値を指定した場合、このパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 各製品の価格は product テーブルに記載されています。浙江省で生産された製品の最高価格を照会します。
   * 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 パラメーターの値を指定した場合、このパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 各製品の価格は product テーブルに記載されています。浙江省で生産された製品の最高価格を照会します。
   * 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 パラメーターの値を指定した場合、このパラメーターの値が行のフィールド値として使用されます。

• 例

  /**
   * 各製品の売上高は product テーブルに一覧表示されています。浙江省で生産された製品の平均価格を照会します。
   * 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());
      }
  }                    

• パラメーター

  パラメーター	説明
  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());
      }
  }

• パラメーター

  パラメーター	説明
  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());
      }
  }

パーセンタイル値は、データセット内の値の相対的な位置を示します。たとえば、システムの日常的な運用保守中に各リクエストの応答時間の統計を収集する場合、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());
          }
      }
  }

フィールド値に基づいてクエリ結果をグループ化するために使用できる集計メソッド。同じ値はグループ化されます。各グループの値と各グループのメンバー数が返されます。

• パラメータ

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

• 例

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

  /**
   * 各カテゴリの製品数、製品の最高価格、最低価格を照会します。
   * 返される結果の例: 果物: 5。 最高価格は 15 人民元、最低価格は 3 人民元です。 洗面用品: 10。 最高価格は 98 人民元、最低価格は 1 人民元です。 電子機器: 3。 最高価格は 8,699 人民元、最低価格は 2,300 人民元です。 その他の製品: 15。 最高価格は 1,000 人民元、最低価格は 80 人民元です。
   */
  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));
  
          //以下のコメントでは、ビルダーを使用してクエリステートメントを作成しています。 ビルダーを使用してクエリステートメントを作成するメソッドは、集計を使用してクエリステートメントを作成するメソッドと同じ効果があります。
          // 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());
          }
      }
  }

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

  /**
   * ネストモードで複数のフィールドによってクエリ結果をグループ化する例。
   * 検索インデックスでは、ネストモードで 2 つの groupBy フィールドを使用して、SQL ステートメントで複数の 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 はネスト操作をサポートしており、親レベルのグループ化結果に基づいてサブレベルの集計を追加できます。

• 一般的なシナリオ

  • 複数レベルのグループ化（GroupBy + SubGroupBy）

    最初のレベルでデータをグループ化した後、2 番目のレベルのグループ化を実行できます。たとえば、最初に県でデータをグループ化し、次に市でグループ化して、各県の各市のデータを取得できます。

  • グループ化後の集計（GroupBy + SubAggregation）

    最初のレベルでデータをグループ化した後、各グループのデータに対して集計操作（最大値や平均値の計算など）を実行できます。たとえば、県別にデータをグループ化した後、各県のグループの特定の指標の最大値を取得できます。

• 例

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

  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("Province:" + item.getKey()
                  + "\tTotal Orders:" + item.getSubAggregationResults().getAsCountAggregationResult("provinceOrderCounts").getValue());
          
          //第 2 レベルのグループ化結果（各市の注文の総数と注文の最大金額）を取得します。
          GroupByFieldResult subResults = item.getSubGroupByResults().getAsGroupByFieldResult("cityName");
          for (GroupByFieldResultItem subItem : subResults.getGroupByFieldResultItems()) {
              System.out.println("\t(City)" + subItem.getKey()
                      + "\tTotal Orders:" + subItem.getSubAggregationResults().getAsCountAggregationResult("cityOrderCounts").getValue()
                      + "\tMaximum Order Amount:" + 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 and 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 and subGroupBy	サブ集計操作。グループ化結果に基づいてサブ集計操作を実行できます。

• 例

  /**
   * 地理的な場所に基づいてユーザーを Wanda Plaza にグループ化し、各距離範囲内のユーザー数を取得します。距離範囲は [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 and 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)  // 返すグループの数を指定します。返されるグループ数の最大値については、「検索インデックスの制限」 Topic の GroupByField で返されるグループ数の説明を参照してください。
                                      .addSubAggregation(AggregationBuilders.topRows("topRowsName")
                                              .limit(1)
                                              .sort(new Sort(Arrays.asList(new FieldSort("teacher", SortOrder.DESC)))) // teacher で降順にソートします。
                                      )
                              )
                              .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());
    }
}