SpringBoot ElasticSearch计算聚合的数据的大小_es 统计平均文档大小

在SpringData Elasticsearch中，聚合统计的原理主要依赖于Elasticsearch本身的聚合框架。Elasticsearch提供了强大的聚合功能，使得你可以对文档进行各种计算和统计，从而得到有关数据集的有用信息。

Elasticsearch的聚合（Aggregation）是一种强大的数据分析和统计工具，它允许你对文档集合进行多层次、多维度的计算和分析。聚合的原理可以分为以下几个方面：

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.index.query.BoolQueryBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.Cardinality;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.collapse.CollapseBuilder;

import java.io.IOException;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class ElasticSearchTest {

    @Autowired
    private RestHighLevelClient client;

    public void getTotalBucket() throws IOException {
        String field = "聚合字段";
        String esIndex = "ES索引";
        // 查询条件
        BoolQueryBuilder builder = new BoolQueryBuilder();

        SearchSourceBuilder source = new SearchSourceBuilder();
        source.query(builder).collapse(new CollapseBuilder(field))
                .aggregation(AggregationBuilders.cardinality(field).field(field));

        SearchRequest request = new SearchRequest();
        request.indices(esIndex);
        request.source(source);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        // 去重总数
        Cardinality cardinality = response.getAggregations().get(field);
        long total = cardinality.getValue();
        System.out.println("总数: " + total);
    }

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43