2020年8月24日星期一

es~通过ElasticsearchTemplate进行聚合操作

聚合操作,我们可以对数据进行分组的求和,求数,最大值,最小值,或者其它的自定义的统计功能,es对聚合有着不错的支持,需要注意的是,在对某字段进行聚合之后,需要开启这个字段的fielddata我,或者会出现如下错误:

Fielddata is disabled on text fields by default.

通过postman等工作像es api发送请求,可以将字段的这个特性打开.

PUT /esdto/esdto/_mapping{ "properties": { "sex": {  "type":  "text",  "fielddata": true } }}

pic
使用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!如何看待亚马逊欧洲站佣金的调整重要提醒!海外仓交易将以最新服务标准进行评估!东莞丽城隐贤山庄怎么样?好玩吗?深圳龙岗到广州天河最早和最晚汽车是什么时候?去广州买什么好?广州购物攻略

没有评论:

发表评论