es多字段分组zjava代码

以下是使用 Java 代码在 Elasticsearch 中进行多字段分组聚合查询的示例：

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.MultiBucketsAggregation;
import org.elasticsearch.search.aggregations.bucket.MultiBucketsAggregation.Bucket;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class MultiFieldGroupBy {
    public void executeMultiFieldGroupBy(RestHighLevelClient client, String index, String field1, String field2) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

        // 构建聚合查询请求
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        searchSourceBuilder.aggregation(AggregationBuilders.terms("group_by_field1").field(field1)
                .subAggregation(AggregationBuilders.terms("group_by_field2").field(field2)));
        searchRequest.source(searchSourceBuilder);

        // 执行聚合查询请求
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        // 解析聚合结果
        Terms field1Terms = searchResponse.getAggregations().get("group_by_field1");
        for (Bucket field1Bucket : field1Terms.getBuckets()) {
            System.out.println("Field1: " + field1Bucket.getKeyAsString());
            Terms field2Terms = field1Bucket.getAggregations().get("group_by_field2");
            for (Bucket field2Bucket : field2Terms.getBuckets()) {
                System.out.println("    Field2: " + field2Bucket.getKeyAsString() + ", Count: " + field2Bucket.getDocCount());
            }
        }
    }
}

在上面的示例中，我们首先构建了一个聚合查询请求，使用“terms”聚合类型分别按照两个字段进行分组。然后，我们执行查询请求，并解析聚合结果以获取每个分组的键和文档计数。