Elasticsearch超强聚合函数(四) buckets的嵌套使用

2024-04-04 22:18

本文主要是介绍Elasticsearch超强聚合函数(四) buckets的嵌套使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  • Elasticsearch超强聚合函数(四) buckets的嵌套使用
      • 案例:构建聚合以便按季度展示所有汽车品牌总销售额。同时按季度、按每个汽车品牌计算销售总额,以便可以找出哪种品牌最赚钱:
        • http代码
        • java-api
        • 返回结果

 

原始数据还是引用第一篇中的数据:ElasticSearch超强聚合查询(一)

案例:构建聚合以便按季度展示所有汽车品牌总销售额。同时按季度、按每个汽车品牌计算销售总额,以便可以找出哪种品牌最赚钱:

http代码

GET /cars/transactions/_search
{"size" : 0,"aggs": {"sales": {"date_histogram": {"field": "sold","interval": "quarter", "format": "yyyy-MM-dd","min_doc_count" : 0,"extended_bounds" : {"min" : "2014-01-01","max" : "2014-12-31"}},"aggs": {"per_make_sum": {"terms": {"field": "make"},"aggs": {"sum_price": {"sum": { "field": "price" } }}},"total_sum": {"sum": { "field": "price" } }}}}
}
  • java-api
@Testpublic void bucketsInsideBuckets(){SearchResponse response = transportClient.prepareSearch("cars").setTypes("transactions").addAggregation(AggregationBuilders.dateHistogram("sales").field("sold").dateHistogramInterval(DateHistogramInterval.QUARTER).format("yyyy-MM-dd").minDocCount(0l).extendedBounds(new ExtendedBounds("2014-01-01","2014-12-31")).subAggregation(//按照季度划分,每个季度所有品牌的的销售额AggregationBuilders.sum("total_sum").field("price"))//添加一个集合的嵌套,在每个季度中,再根据品牌进行划分.subAggregation(AggregationBuilders.terms("per_make_sum").field("make").subAggregation(//计算各个品牌在每个解读中的销售额AggregationBuilders.sum("sum_price").field("price")))).setSize(0).get();Aggregation sales = response.getAggregations().get("sales");System.out.println(sales);
  • 返回结果
{"took": 1,"timed_out": false,"_shards": {"total": 5,"successful": 5,"skipped": 0,"failed": 0},"hits": {"total": 7,"max_score": 0.0,"hits": []},"aggregations": {"sales": {"buckets": [{"key_as_string": "2014-01-01",//第一个季度"key": 1388534400000,"doc_count": 1,"per_make_sum": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "bmw","doc_count": 1,"sum_price": {//各个品牌的销售总额"value": 80000.0}}]},"total_sum": {//所有品牌销售总额"value": 80000.0}},{"key_as_string": "2014-04-01","key": 1396310400000,"doc_count": 1,"per_make_sum": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "ford","doc_count": 1,"sum_price": {"value": 30000.0}}]},"total_sum": {"value": 30000.0}},{"key_as_string": "2014-07-01","key": 1404172800000,"doc_count": 2,"per_make_sum": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "toyota","doc_count": 2,"sum_price": {"value": 27000.0}}]},"total_sum": {"value": 27000.0}},{"key_as_string": "2014-10-01","key": 1412121600000,"doc_count": 3,"per_make_sum": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "honda","doc_count": 3,"sum_price": {"value": 50000.0}}]},"total_sum": {"value": 50000.0}}]}}
}

这篇关于Elasticsearch超强聚合函数(四) buckets的嵌套使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/876937

相关文章

全面掌握 SQL 中的 DATEDIFF函数及用法最佳实践

《全面掌握SQL中的DATEDIFF函数及用法最佳实践》本文解析DATEDIFF在不同数据库中的差异,强调其边界计算原理,探讨应用场景及陷阱,推荐根据需求选择TIMESTAMPDIFF或inte... 目录1. 核心概念:DATEDIFF 究竟在计算什么?2. 主流数据库中的 DATEDIFF 实现2.1

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

MySQL中的LENGTH()函数用法详解与实例分析

《MySQL中的LENGTH()函数用法详解与实例分析》MySQLLENGTH()函数用于计算字符串的字节长度,区别于CHAR_LENGTH()的字符长度,适用于多字节字符集(如UTF-8)的数据验证... 目录1. LENGTH()函数的基本语法2. LENGTH()函数的返回值2.1 示例1:计算字符串

prometheus如何使用pushgateway监控网路丢包

《prometheus如何使用pushgateway监控网路丢包》:本文主要介绍prometheus如何使用pushgateway监控网路丢包问题,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录监控网路丢包脚本数据图表总结监控网路丢包脚本[root@gtcq-gt-monitor-prome

Python通用唯一标识符模块uuid使用案例详解

《Python通用唯一标识符模块uuid使用案例详解》Pythonuuid模块用于生成128位全局唯一标识符,支持UUID1-5版本,适用于分布式系统、数据库主键等场景,需注意隐私、碰撞概率及存储优... 目录简介核心功能1. UUID版本2. UUID属性3. 命名空间使用场景1. 生成唯一标识符2. 数

SpringBoot中如何使用Assert进行断言校验

《SpringBoot中如何使用Assert进行断言校验》Java提供了内置的assert机制,而Spring框架也提供了更强大的Assert工具类来帮助开发者进行参数校验和状态检查,下... 目录前言一、Java 原生assert简介1.1 使用方式1.2 示例代码1.3 优缺点分析二、Spring Fr

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

java使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

C++ Log4cpp跨平台日志库的使用小结

《C++Log4cpp跨平台日志库的使用小结》Log4cpp是c++类库,本文详细介绍了C++日志库log4cpp的使用方法,及设置日志输出格式和优先级,具有一定的参考价值,感兴趣的可以了解一下... 目录一、介绍1. log4cpp的日志方式2.设置日志输出的格式3. 设置日志的输出优先级二、Window