ES聚合去重 java实现

在 Java 中使用 Elasticsearch 进行聚合并去重，您可以借助 Elasticsearch 的 Java 客户端库进行实现。以下是一个示例代码片段，演示如何使用 Java 客户端进行聚合去重操作：

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class ESQueryAggregation {
    public static void main(String[] args) {
        // 创建 Elasticsearch 客户端
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));

        // 创建聚合查询请求
        SearchRequest searchRequest = new SearchRequest("your_index");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

        // 设置查询条件（可根据需求自行调整）
        sourceBuilder.query(QueryBuilders.matchAllQuery());

        // 添加聚合操作（使用 Terms Aggregation 进行去重）
        sourceBuilder.aggregation(AggregationBuilders.terms("unique_values").field("your_field").size(10));

        searchRequest.source(sourceBuilder);

        try {
            // 执行查询
            SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

            // 处理聚合结果
            Terms uniqueValues = searchResponse.getAggregations().get("unique_values");
            for (Terms.Bucket bucket : uniqueValues.getBuckets()) {
                String uniqueValue = bucket.getKeyAsString();
                System.out.println("Unique Value: " + uniqueValue);
            }

            // 关闭 Elasticsearch 客户端
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

请注意，上述代码中的 "your_index" 和 "your_field" 需要替换为您实际的索引名称和字段名称。另外，您需要将 Elasticsearch 的 Java 客户端库添加到您的项目依赖中。

这是一个简单的示例，您可以根据自己的需求进行调整和扩展。希望对您有所帮助！如果您有任何其他问题，请随时提问。