聚合操作,我们可以对数据进行分组的求和,求数,最大值,最小值,或者其它的自定义的统计功能,es对聚合有着不错的支持,需要注意的是,在对某字段进行聚合之后,需要开启这个字段的fielddata我,或者会出现如下错误:
Fielddata is disabled on text fields by default.
通过postman等工作像es api发送请求,可以将字段的这个特性打开.
PUT /esdto/esdto/_mapping{ "properties": { "sex": { "type": "text", "fielddata": true } }}
使用ElasticsearchTemplate对sex字段进行聚合
// 创建一个查询条件对象 BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery(); // 拼接查询条件 queryBuilder.should(QueryBuilders.termQuery("creator", "1")); // 创建聚合查询条件 TermsAggregationBuilder agg = AggregationBuilders.terms("sex").field("sex.keyword");//keyword表示不使用分词进行聚合 // 创建查询对象 SearchQuery build = new NativeSearchQueryBuilder() .withQuery(queryBuilder) //添加查询条件 .addAggregation(agg) // 添加聚合条件 .withPageable(PageRequest.of(0, 10)) //符合查询条件的文档分页(不是聚合的分页) .build(); // 执行查询 AggregatedPage<TestEsDto> testEntities = elasticsearchTemplate.queryForPage(build, TestEsDto.class); // 取出聚合结果 Aggregations entitiesAggregations = testEntities.getAggregations(); Terms terms = (Terms) entitiesAggregations.asMap().get("sex"); // 遍历取出聚合字段列的值,与对应的数量 for (Terms.Bucket bucket : terms.getBuckets()) { String keyAsString = bucket.getKeyAsString(); // 聚合字段列的值 long docCount = bucket.getDocCount();// 聚合字段对应的数量 log.info("keyAsString={},value={}", keyAsString, docCount); }
es~通过ElasticsearchTemplate进行聚合操作跨国采购网、 wish站外的风景更精彩、 亚马逊平台选品与优化、 超5亿英镑!蚂蚁金服或将收购WorldFirst!、 如何看待亚马逊欧洲站佣金的调整、 重要提醒!海外仓交易将以最新服务标准进行评估!、 东莞丽城隐贤山庄怎么样?好玩吗?、 深圳龙岗到广州天河最早和最晚汽车是什么时候?、 去广州买什么好?广州购物攻略、
没有评论:
发表评论