集团主站
欢迎来到成都达内官方网站!达内—美国上市公司 亿元级外企IT培训企业!
成都it培训哪家好
成都it培训哪家好
全国服务监督电话:15023458194  |   联系客服   |
当前位置:主页 > 培训课程 > 大数据 >

成都大数据学习路线:Nested嵌套聚合

发布者: 成都达内     浏览次数:     发布时间:2020-09-09 11:35:37

成都大数据学习路线:Nested是一种嵌套文档,类似于父子文档,它可以将与主文档有关的数据进行存储,可以把它理解成一张子表,它的查询和聚合性能很好;更新性能一般。...

  Nested是一种嵌套文档,类似于父子文档,它可以将与主文档有关的数据进行存储,可以把它理解成一张子表,它的查询和聚合性能很好;更新性能一般。

  下面是测试使用的数据结构,一个包含Nested属性的实体@Document(indexName = "esdto", type = "esdto")

  @Data

  @ToString(callSuper = true)

  @AllArgsConstructor

  @NoArgsConstructor

  public class TestEsDto extends EsBaseEntity implements Serializable {

  @Field(type = FieldType.Keyword)

  private String name;

  private Integer age;

  @Field(type = FieldType.Keyword)

  private String sex;

  @Field(type = FieldType.Keyword)

  private String desc;

  @Field(type = FieldType.Nested)

  private List personList;

  @Data

  @AllArgsConstructor

  @NoArgsConstructor

  @ToString

  public static class Person {

  private Integer age;

  @Field(type = FieldType.Keyword)

  private String sex;

  @Field(type = FieldType.Keyword)

  private String desc;

  }

  }

  存储的数据如图

  成都大数据学习路线:Nested嵌套聚合

  聚合代码 // 创建一个查询条件对象

  BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();

  // 拼接查询条件

  queryBuilder.should(QueryBuilders.termQuery("creator", "1"));

  // 嵌套聚合

  AbstractAggregationBuilder aggregation =

  AggregationBuilders

  .nested("personList", "personList")

  .subAggregation(AggregationBuilders

  .terms("sex").field("personList.sex")

  .subAggregation(

  AggregationBuilders

  .terms("desc").field("personList.desc")

  .subAggregation(

  AggregationBuilders

  .sum("ageSum").field("personList.age")

  )

  )

  );

  // 创建查询对象

  SearchQuery build = new NativeSearchQueryBuilder()

  .withQuery(queryBuilder) //添加查询条件

  .addAggregation(aggregation) // 添加聚合条件

  .withPageable(PageRequest.of(0, 1)) //符合查询条件的文档分页,如果文档比较大,可以把这个分页改小(不是聚合的分页)

  .build();

  // 执行查询

  AggregatedPage testEntities = elasticsearchTemplate.queryForPage(build, TestEsDto.class);

  // 取出聚合结果

  Nested agg = testEntities.getAggregations().get("personList");

  Terms terms = agg.getAggregations().get("sex");

  // 遍历

  for (Terms.Bucket bucket : terms.getBuckets()) {

  Terms descTerms = bucket.getAggregations().get("desc");

  for (Terms.Bucket descTermsBucket : descTerms.getBuckets()) {

  ParsedSum parsedSum = descTermsBucket.getAggregations().get("ageSum");//注意从bucket而不是searchResponse

  System.out.println(bucket.getKeyAsString() + "\t" +

  bucket.getDocCount() + "\t" +

  descTermsBucket.getKeyAsString() + "\t" +

  parsedSum.getValueAsString());

  }

  }

  运行结果

  成都大数据学习路线:Nested嵌套聚合

(责任编辑:范老师)
最新开班
  • 成都Java培训班
    免费试听名额发放中...
  • 成都C++培训班
    免费试听名额发放中...
  • 成都PHP培训班
    免费试听名额发放中...
  • 成都网络工程培训班
    免费试听名额发放中...
  • 成都Unity3D培训班
    免费试听名额发放中...
  • 成都大数据培训班
    免费试听名额发放中...
  • 成都uid培训班
    免费试听名额发放中...
  • 成都会计培训班
    免费试听名额发放中...
  • 成都Python培训班
    免费试听名额发放中...
  • 成都嵌入式培训班
    免费试听名额发放中...
  • 成都web培训班
    免费试听名额发放中...
  • 成都软件测试培训班
    免费试听名额发放中...
在线留言
提交

校区地址:成都市锦江区东大街紫东楼端35号明宇金融广场19楼1906室

联系电话:15023458194

公交路线:芷泉街(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:成都市高新区奥克斯广场蜀锦路209号一楼商铺

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

校区地址:成都锦江区东大街芷泉街229号东方广场C座3楼303

联系电话:15023458194

公交路线:芷泉街(188路;115路;515路;236路;505路;501路;84路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:成都市武侯区佳灵路3号红牌楼广场2号写字楼11楼1115号

联系电话:15023458194

公交路线:红牌楼东(11路;92路;100路;111路;139路;g28路;快速公交K1/K2) 地铁路线:红牌楼站(地铁3号线)

校区地址:成都市锦江区红星路二段70号四川日报大厦502-2

联系电话:15023458194

公交路线:市二医院站(6路;49路;102路;5路;37路;g92路;) 地铁路线:地铁市二医院(地铁3号线)

校区地址:成都市锦江区东大街芷泉段229号东方广场C座16层

联系电话:15023458194

公交路线:芷泉街(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:四川省成都市武侯区高新科技孵化园9号园区E座7楼

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

校区地址:成都市高新区奥克斯广场B座1708

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

了解达内动态
关注成都达内教育公众号

首页 | 关于达内 | 课程中心 | 专家师资 | 视频教程 | 学员空间 | 校企合作 | 新闻资讯 | 就业指导 | 网站地图

2016-2025 达内时代科技集团有限公司 版权所有 京ICP证8000853号-56