elasticsearch聚合查询

作者注:本文系作者自己的理解.希望大家多多交流指正

官网java API

term是代表完全匹配，也就是精确查询，搜索前不会再对搜索词进行分词，所以我们的搜索词必须是文档分词集合中的一个

TermsBuilder:构造聚合函数

AggregationBuilders:创建聚合函数工具类

BoolQueryBuilder:拼装连接(查询)条件

QueryBuilders:简单的静态工厂”导入静态”使用。主要作用是查询条件(关系),如区间精确多值等条件

NativeSearchQueryBuilder:将连接条件和聚合函数等组合

SearchQuery:生成查询

elasticsearchTemplate.query:进行查询

Aggregations:Represents a set of computed addAggregation.代表一组添加聚合函数统计后的数据

Bucket:满足某个条件(聚合)的文档集合

使用示例：

public Map<String, Long> yananList(String str) {

Calendar c = Calendar.getInstance();
        c.setTime(new Date());
        c.add(Calendar.MONTH, -1);
        long start=c.getTimeInMillis();
        long end=System.currentTimeMillis();
        Map<String, Long> map = new HashMap<String, Long>();
        
        //子查询
        TermsBuilder tb= AggregationBuilders.terms("yanan7890")
                .field("需要聚合的字段").order(Terms.Order.count(false)).size(int size（默认10）);    //yanan7890是为聚合取的名称,false降序,true升序
        //查询条件
        BoolQueryBuilder bqb = QueryBuilders.boolQuery();
        bqb.must(QueryBuilders.termQuery(string name,  str);
        bqb.must(QueryBuilders.rangeQuery("starttime").gt(start));// 大于
        bqb.must(QueryBuilders.rangeQuery("endtime").lt(end));// 小于
        //执行查询条件

　　　/**

　　　　*SearchType.COUNT，Only counts the results, will still execute facets and the like.

　　　　*EsIndexs.yanan7890指定索引

　　　　*/
        SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(bqb)
                .withSearchType(SearchType.COUNT)
                .withIndices(EsIndexs.yanan7890)
                .addAggregation(tb).build();
        
        
        // when
        Aggregations aggregations = elasticsearchTemplate.query(searchQuery,
                new ResultsExtractor<Aggregations>() {
                    @Override
                    public Aggregations extract(SearchResponse response) {
                        return response.getAggregations();
                    }
                });
        
        
        LongTerms modelTerms = (LongTerms) aggregations.asMap().get("yanan7890");//yanan7890是前面指定的聚合名称.
        
        Iterator<Bucket> modelBucketIt = modelTerms.getBuckets().iterator();
        while (modelBucketIt.hasNext()) {
            Bucket actiontypeBucket = modelBucketIt.next();

//actiontypeBucket.getKey().toString()聚合字段的相应名称,actiontypeBucket.getDocCount()相应聚合结果
            map.put(actiontypeBucket.getKey().toString(),
                    actiontypeBucket.getDocCount());
        }
        return map;