es aggregation java_Java Elasticsearch 聚合查询(Aggregation)详解

Elasticsearch 是一个分布式的全文搜索和分析引擎，它提供了丰富的聚合功能用于数据分析。聚合查询可以让你在 Elasticsearch 中执行各种各样的统计操作，例如计算平均值、最大值、最小值、总和等等。

下面是一个使用 Java API 进行聚合查询的示例：

// 创建一个 SearchRequest 对象
SearchRequest searchRequest = new SearchRequest("index_name");

// 构建一个聚合查询
AggregationBuilder aggregation = AggregationBuilders
        .terms("by_country")
        .field("country")
        .subAggregation(AggregationBuilders
                .avg("avg_price")
                .field("price"));

// 将聚合查询添加到 SearchRequest 中
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.aggregation(aggregation);
searchRequest.source(searchSourceBuilder);

// 执行搜索
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

// 处理聚合结果
Terms byCountryAggregation = searchResponse.getAggregations().get("by_country");
for (Terms.Bucket bucket : byCountryAggregation.getBuckets()) {
    String country = bucket.getKeyAsString();
    Avg avgPriceAggregation = bucket.getAggregations().get("avg_price");
    double avgPrice = avgPriceAggregation.getValue();
    System.out.println("Country: " + country + ", Avg Price: " + avgPrice);
}

上面的代码中，我们创建了一个 SearchRequest 对象，并且构建了一个名为 "by_country" 的 terms 聚合查询，用于按国家统计数据，并且在每个国家下面计算平均价格。然后将聚合查询添加到 SearchRequest 中并执行搜索，最后处理聚合结果。

聚合查询是 Elasticsearch 中非常重要的一个功能，可以帮助我们更好地了解数据，并从中得出有用的结论。在实际开发中，我们需要根据具体的需求选择不同的聚合方式，并且合理地使用缓存和优化技巧来提高查询性能。