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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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("<テーブル名>")
                  .indexName("<検索インデックス名>")
                  .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("<テーブル名>");
          searchRequest.setIndexName("<検索インデックス名>");
  
          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());
          }
      }
  }

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

  /**
   * ネストモードでの複数フィールドによるクエリ結果のグループ化の例。
   * 検索インデックスでは、ネストモードで 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("<テーブル名>")
          .indexName("<検索インデックス名>")
          .returnAllColumns(true)   //returnAllColumns を false に設定し、addColumesToGet の値を指定すると、クエリのパフォーマンスが向上します。
          //.addColumnsToGet("col_1","col_2")
          .searchQuery(SearchQuery.newBuilder()
              .query(QueryBuilders.matchAll())   //クエリ条件を指定します。クエリ条件は、SQL の WHERE 句と同じように使用できます。QueryBuilders.bool() を使用して、ネストされたクエリを実行できます。
              .addGroupBy(
                  GroupByBuilders
                      .groupByField("一意の名前_1", "field_a")
                      .size(20)
                      .addSubGroupBy(
                          GroupByBuilders
                              .groupByField("一意の名前_2", "field_d")
                              .size(20)
                              .addSubAggregation(AggregationBuilders.sum("一意の名前_3", "field_b"))
                              .addSubAggregation(AggregationBuilders.sum("一意の名前_4", "field_c"))
                      )
              )
              .build())
          .build();
      SearchResponse response = client.search(searchRequest);
      //指定された条件を満たす行をクエリします。
      List<Row> rows = response.getRows();
      //集計結果を取得します。
      GroupByFieldResult groupByFieldResult1 = response.getGroupByResults().getAsGroupByFieldResult("一意の名前_1");
      for (GroupByFieldResultItem resultItem : groupByFieldResult1.getGroupByFieldResultItems()) {
          System.out.println("field_a key:" + resultItem.getKey() + " Count:" + resultItem.getRowCount());
          //サブ集計結果を取得します。
          GroupByFieldResult subGroupByResult = resultItem.getSubGroupByResults().getAsGroupByFieldResult("一意の名前_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("一意の名前_3").getValue();
              double sumOf_field_c = item.getSubAggregationResults().getAsSumAggregationResult("一意の名前_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("<テーブル名>")
          .indexName("<検索インデックス名>")
          .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);
  }

フィールドの値の範囲に基づいてクエリ結果をグループ化するために使用できる集計方法。特定の範囲内にあるフィールド値は一緒にグループ化されます。各範囲の値の数が返されます。

• パラメーター

  パラメーター	説明
  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("<テーブル名>")
          .indexName("<検索インデックス名>")
          .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	サブ集計操作。グループ化結果に基づいてサブ集計操作を実行できます。

• 例

  /**
   * ユーザーを万達広場への地理的位置に基づいてグループ化し、各距離範囲内のユーザー数を取得します。距離範囲は [0, 1000)、[1000, 5000)、および [5000, Double.MAX_VALUE) です。単位: メートル。
   */
  public void groupByGeoDistance(SyncClient client) {
      //クエリ文を作成します。
      SearchRequest searchRequest = SearchRequest.newBuilder()
          .tableName("<テーブル名>")
          .indexName("<検索インデックス名>")
          .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("<テーブル名>")
          .indexName("<検索インデックス名>")
          .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("<テーブル名>")
          .indexName("<検索インデックス名>")
          .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	返すフィールド。検索インデックス内のフィールドのみがサポートされます。Array、Date、Geopoint、および Nested フィールドはサポートされていません。 このパラメーターの値は、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("<検索インデックス名>")
              .tableName("<テーブル名>")
              .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("<テーブル名>")
        .indexName("<検索インデックス名>")
        .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("<テーブル名>")
        .indexName("<検索インデックス名>")
        .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());
    }
}