技术标签: 程序员 elasticsearch 大数据 sql
其他参数:
当管道聚合遇到不存在的值,有点类似于term等聚合的(missing)时所采取的策略,可选择值为:skip、insert_zeros。
skip:此选项将丢失的数据视为bucket不存在。它将跳过桶并使用下一个可用值继续计算。
insert_zeros:默认使用0代替。
format
用于格式化聚合桶的输出(key)。
示例如下:
POST /_search
{
“size”: 0,
“aggs”: {
“sales_per_month”: { // @1
“date_histogram”: {
“field”: “date”,
“interval”: “month”
},
“aggs”: { // @2
“sales”: {
“sum”: {
“field”: “price”
}
}
}
},
“avg_monthly_sales”: { // @3
“avg_bucket”: {
“buckets_path”: “sales_per_month>sales”
}
}
}
}
代码@1:首先定义第一级聚合(按月)直方图聚合。
代码@2:定义第二级聚合,在按月聚合的基础上,对每个月的文档求sum。
代码@3:对上面的聚合求平均值。
其返回结果如下:
{
… // 省略
“aggregations”: {
“sales_per_month”: {
“buckets”: [
{
“key_as_string”: “2015/01/01 00:00:00”,
“key”: 1420070400000,
“doc_count”: 3,
“sales”: {
“value”: 550.0
}
},
{
“key_as_string”: “2015/02/01 00:00:00”,
“key”: 1422748800000,
“doc_count”: 2,
“sales”: {
“value”: 60.0
}
}
]
},
“avg_monthly_sales”: { // 这是对二级聚合的结果再进行一次求平均值聚合。
“value”: 328.33333333333333
}
}
}
对应的JAVA示例如下:
public static void test_pipeline_avg_buncket_aggregation() {
RestHighLevelClient client = EsClient.getClient();
try {
SearchRequest searchRequest = new SearchRequest();
searchRequest.indices(“aggregations_index02”);
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
AggregationBuilder aggregationBuild = AggregationBuilders.terms(“seller_agg”)
.field(“sellerId”)
.subAggregation(AggregationBuilders.sum(“seller_num_agg”)
.field(“num”)
)
;
sourceBuilder.aggregation(aggregationBuild);
// 添加 avg bucket pipeline
sourceBuilder.aggregation(new AvgBucketPipelineAggregationBuilder(“seller_num_agg_av”, “seller_agg>seller_num_agg”));
sourceBuilder.size(0);
searchRequest.source(sourceBuilder);
SearchResponse result = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println(result);
} catch (Throwable e) {
e.printStackTrace();
} finally {
EsClient.close(client);
}
}
2、Percentiles Bucket Aggregation
同级管道聚合,百分位管道聚合。其JAVA示例如下:
public static void test_Percentiles_buncket_aggregation() {
RestHighLevelClient client = EsClient.getClient();
try {
SearchRequest searchRequest = new SearchRequest();
searchRequest.indices(“aggregations_index02”);
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
AggregationBuilder aggregationBuild = AggregationBuilders.terms(“seller_agg”)
.field(“sellerId”)
.subAggregation(AggregationBuilders.sum(“seller_num_agg”)
.field(“num”)
)
;
sourceBuilder.aggregation(aggregationBuild);
// 添加 avg bucket pipeline
sourceBuilder.aggregation(new PercentilesBucketPipelineAggregationBuilder(“seller_num_agg_av”, “seller_agg>seller_num_agg”));
sourceBuilder.size(0);
searchRequest.source(sourceBuilder);
SearchResponse result = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println(result);
} catch (Throwable e) {
e.printStackTrace();
} finally {
EsClient.close(client);
}
}
其返回值如下:
{
… // 省略其他属性
“aggregations”:{
“lterms#seller_agg”:{
“doc_count_error_upper_bound”:0,
“sum_other_doc_count”:12,
“buckets”:[
{
“key”:45,
“doc_count”:567,
“sum#seller_num_agg”:{
“value”:911
}
},
{
“key”:31,
“doc_count”:324,
“sum#seller_num_agg”:{
“value”:353
}
} // 省略其他桶的显示
]
},
“percentiles_bucket#seller_num_agg_av”:{
“values”:{
“1.0”:5,
“5.0”:5,
“25.0”:10,
“50.0”:20,
“75.0”:290,
“95.0”:911,
“99.0”:911
}
}
}
}
3、Cumulative Sum Aggregation
累积管道聚合,就是就是依次将每个管道的sum聚合进行累加。
其语法(restfull)如下:
{
“cumulative_sum”: {
“buckets_path”: “the_sum”
}
}
支持的参数说明:
桶聚合名称,作为管道聚合的输入信息。
格式化key。
使用示例如下:
POST /sales/_search
{
“size”: 0,
“aggs” : {
“sales_per_month” : {
“date_histogram” : {
“field” : “date”,
“interval” : “month”
},
“aggs”: {
“sales”: {
“sum”: {
“field”: “price”
}
},
“cumulative_sales”: {
“cumulative_sum”: {
“buckets_path”: “sales”
}
}
}
}
}
}
其返回结果如下:
{
“took”: 11,
“timed_out”: false,
“_shards”: …,
“hits”: …,
“aggregations”: {
“sales_per_month”: {
“buckets”: [
{
“key_as_string”: “2015/01/01 00:00:00”,
“key”: 1420070400000,
“doc_count”: 3,
“sales”: {
“value”: 550.0
},
“cumulative_sales”: {
“value”: 550.0
}
},
{
“key_as_string”: “2015/02/01 00:00:00”,
“key”: 1422748800000,
“doc_count”: 2,
“sales”: {
“value”: 60.0
},
“cumulative_sales”: {
“value”: 610.0
}
},
{
“key_as_string”: “2015/03/01 00:00:00”,
“key”: 1425168000000,
“doc_count”: 2,
“sales”: {
“value”: 375.0
},
“cumulative_sales”: {
“value”: 985.0
}
}
]
}
}
}
从结果可知,cumulative_sales的值等于上一个cumulative_sales + 当前桶的sum聚合。
对应的JAVA示例如下:
{
“aggregations”:{
“date_histogram#createTime_histogram”:{
“buckets”:{
“2015-12-01 00:00:00”:{
“key_as_string”:“2015-12-01 00:00:00”,
“key”:1448928000000,
“doc_count”:6,
“sum#seller_num_agg”:{
“value”:16
},
“simple_value#Cumulative_Seller_num_agg”:{
“value”:16
}
},
“2016-01-01 00:00:00”:{
“key_as_string”:“2016-03-01 00:00:00”,
“key”:1456790400000,
“doc_count”:10,
“sum#seller_num_agg”:{
“value”:11
},
“simple_value#Cumulative_Seller_num_agg”:{
“value”:31
}
}
// … 忽略
}
}
}
}
4、Bucket Sort Aggregation
一种父管道聚合,它对其父多桶聚合的桶进行排序。并可以指定多个排序字段。每个bucket可以根据它的_key、_count或子聚合进行排序。此外,可以设置from和size的参数,以便截断结果桶。
使用语法如下:
{
“bucket_sort”: {
“sort”: [
{“sort_field_1”: {“order”: “asc”}},
{“sort_field_2”: {“order”: “desc”}},
“sort_field_3”
],
“from”: 1,
“size”: 3
}
}
支持的参数说明如下:
定义排序结构。
用与对父聚合的桶进行截取,该值之前的所有桶将忽略,也就是不参与排序,默认为0。
自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。
深知大多数Java工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!
因此收集整理了一份《2024年Java开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。
既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Java开发知识点,真正体系化!
由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且会持续更新!
如果你觉得这些内容对你有帮助,可以扫码获取!!(备注Java获取)
经过日积月累, 以下是小编归纳整理的深入了解Java虚拟机文档,希望可以帮助大家过关斩将顺利通过面试。
由于整个文档比较全面,内容比较多,篇幅不允许,下面以截图方式展示 。
由于篇幅限制,文档的详解资料太全面,细节内容太多,所以只把部分知识点截图出来粗略的介绍,每个小节点里面都有更细化的内容!
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!
果你觉得这些内容对你有帮助,可以扫码获取!!(备注Java获取)**
经过日积月累, 以下是小编归纳整理的深入了解Java虚拟机文档,希望可以帮助大家过关斩将顺利通过面试。
由于整个文档比较全面,内容比较多,篇幅不允许,下面以截图方式展示 。
[外链图片转存中…(img-rGoYI77g-1713084372281)]
[外链图片转存中…(img-KjM4veGo-1713084372281)]
[外链图片转存中…(img-PwUTx0Ue-1713084372281)]
[外链图片转存中…(img-0lUNAAhZ-1713084372281)]
[外链图片转存中…(img-IydV1peg-1713084372282)]
[外链图片转存中…(img-EBWdLLUi-1713084372282)]
[外链图片转存中…(img-UDWg53vm-1713084372282)]
由于篇幅限制,文档的详解资料太全面,细节内容太多,所以只把部分知识点截图出来粗略的介绍,每个小节点里面都有更细化的内容!
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!
文章浏览阅读3.8k次,点赞9次,收藏28次。直接上一个工作中碰到的问题,另外一个系统开启多线程调用我这边的接口,然后我这边会开启多线程批量查询第三方接口并且返回给调用方。使用的是两三年前别人遗留下来的方法,放到线上后发现确实是可以正常取到结果,但是一旦调用,CPU占用就直接100%(部署环境是win server服务器)。因此查看了下相关的老代码并使用JProfiler查看发现是在某个while循环的时候有问题。具体项目代码就不贴了,类似于下面这段代码。while(flag) {//your code;}这里的flag._main函数使用while(1)循环cpu占用99
文章浏览阅读347次。idea shift f6 快捷键无效_idea shift +f6快捷键不生效
文章浏览阅读135次。Ecmacript 中没有DOM 和 BOM核心模块Node为JavaScript提供了很多服务器级别,这些API绝大多数都被包装到了一个具名和核心模块中了,例如文件操作的 fs 核心模块 ,http服务构建的http 模块 path 路径操作模块 os 操作系统信息模块// 用来获取机器信息的var os = require('os')// 用来操作路径的var path = require('path')// 获取当前机器的 CPU 信息console.log(os.cpus._node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是
文章浏览阅读10w+次,点赞435次,收藏3.4k次。SPSS 22 下载安装过程7.6 方差分析与回归分析的SPSS实现7.6.1 SPSS软件概述1 SPSS版本与安装2 SPSS界面3 SPSS特点4 SPSS数据7.6.2 SPSS与方差分析1 单因素方差分析2 双因素方差分析7.6.3 SPSS与回归分析SPSS回归分析过程牙膏价格问题的回归分析_化工数学模型数据回归软件
文章浏览阅读7.5k次。如何利用hutool工具包实现邮件发送功能呢?1、首先引入hutool依赖<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.19</version></dependency>2、编写邮件发送工具类package com.pc.c..._hutool发送邮件
文章浏览阅读867次,点赞2次,收藏2次。docker安装elasticsearch,elasticsearch-head,kibana,ik分词器安装方式基本有两种,一种是pull的方式,一种是Dockerfile的方式,由于pull的方式pull下来后还需配置许多东西且不便于复用,个人比较喜欢使用Dockerfile的方式所有docker支持的镜像基本都在https://hub.docker.com/docker的官网上能找到合..._docker安装kibana连接elasticsearch并且elasticsearch有密码
文章浏览阅读1.3w次,点赞57次,收藏92次。整理 | 郑丽媛出品 | CSDN(ID:CSDNnews)近年来,随着机器学习的兴起,有一门编程语言逐渐变得火热——Python。得益于其针对机器学习提供了大量开源框架和第三方模块,内置..._beeware
文章浏览阅读7.9k次。//// ViewController.swift// Day_10_Timer//// Created by dongqiangfei on 2018/10/15.// Copyright 2018年 飞飞. All rights reserved.//import UIKitclass ViewController: UIViewController { ..._swift timer 暂停
文章浏览阅读986次,点赞2次,收藏2次。1.硬性等待让当前线程暂停执行,应用场景:代码执行速度太快了,但是UI元素没有立马加载出来,造成两者不同步,这时候就可以让代码等待一下,再去执行找元素的动作线程休眠,强制等待 Thread.sleep(long mills)package com.example.demo;import org.junit.jupiter.api.Test;import org.openqa.selenium.By;import org.openqa.selenium.firefox.Firefox.._元素三大等待
文章浏览阅读3k次,点赞4次,收藏14次。Java软件工程师职位分析_java岗位分析
文章浏览阅读2k次。Java:Unreachable code的解决方法_java unreachable code
文章浏览阅读1w次。1、html中设置标签data-*的值 标题 11111 222222、点击获取当前标签的data-url的值$('dd').on('click', function() { var urlVal = $(this).data('ur_如何根据data-*属性获取对应的标签对象