Elasticsearch 5.x Java api Aggregations(聚合)

港控/mmm° 2022-06-06 14:00 282阅读 0赞

Ealsticsearch 5.x Java API聚合string 类型的时候，会报错（json的错），则需要在聚合的string类型字段的后面添加.keyword , 虽然使用watch查看聚合的es json的时候会出现以下报错，但是不会影响结果。

## 1、[Metrics Aggregations][](度量聚合) ##

### 1)、MinAggregation(最小值聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 2)、MaxAggregation(最大值聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 3)、SumAggregation(求和聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 4) 、AvgAggregation(平均数聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 5)、StatsAggregation(统计聚合) ###

统计聚合即一次性获取最小值、最小值、平均值、求和、统计聚合的集合。

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 6) 、Extended Stats Aggregation(扩展统计聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 7) 、Values CountAggregation(值计数聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 8) 、Percentile Aggregation(百分位聚合) ###

#### 1、Prepare aggregation request ####

自定义百分比：

#### 2、Use aggregation response ####

#### 3、Result ####

### 9)、Percentile Ranks Aggregation(百分等级聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

#### 3、Result ####

### 10)、Cardinality Aggregation(基数聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 11)、Geo Bounds Aggregation(地理限制聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

#### 3、Result ####

### 12)、Top Hits Aggregation(top n 聚合) ###

#### 1）、Prepare aggregation request ####

#### 1、只查询分组的top 1： ####

2、查询分组的top n：

#### 2）、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.terms.Terms; import org.elasticsearch.search.aggregations.metrics.tophits.TopHits; // sr is here your SearchResponse object Terms agg = sr.getAggregations().get("agg"); // For each entry for (Terms.Bucket entry : agg.getBuckets()) { &nbsp;&nbsp;&nbsp;&nbsp;String key = entry.getKey(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// bucket key &nbsp;&nbsp;&nbsp;&nbsp;long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Doc count &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], doc_count [{}]", key, docCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;// We ask for top_hits for each bucket &nbsp;&nbsp;&nbsp;&nbsp;TopHits topHits = entry.getAggregations().get("top"); &nbsp;&nbsp;&nbsp;&nbsp;for (SearchHit hit : topHits.getHits().getHits()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.info(" -&gt; id [{}], _source [{}]", hit.getId(), hit.getSourceAsString()); &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

#### 3）、查询结果： ####

### 13)、Scripted Metric Aggregation(脚本度量聚合) ###

#### 1、maven依赖 ####

#### 1、Prepare aggregation request ####

You can also specify a combine script which will be executed on each shard:

You can also specify a reduce script which will be executed on the node which gets the request:

#### 2、Use aggregation response ####

#### 3、Result ####

result1:

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> scriptedResult object [ArrayList] scriptedResult [ { "heights" : [ 1.122218480146643, -1.8148918111233887, -1.7626731575142909, ... ] }, { "heights" : [ -0.8046067304119863, -2.0785486707864553, -1.9183567430207953, ... ] }, { "heights" : [ 2.092635728868694, 1.5697545960886536, 1.8826954461968808, ... ] }, { "heights" : [ -2.1863201099468403, 1.6328549117346856, -1.7078288405893842, ... ] }, { "heights" : [ 1.6043904836424177, -2.0736538674414025, 0.9898266674373053, ... ] } ] </td> 
 </tr> 
 </tbody> 
</table>

Result2:

Result3:

## 2、[Bucket Aggregations][](桶聚合) ##

### 1) 、Global Aggregation(整体聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 2)、Filter Aggregation(过滤聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 3)、Filter Aggregation(多过滤聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 4) 、Missing Aggregation(失踪聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 5)、Nested Aggregation(嵌套聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 6)、Reverse Nested Aggregation(反向嵌套聚合) ###

#### 1、Prepare aggregation request ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> AggregationBuilder aggregation = &nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.nested("agg", "resellers") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.subAggregation( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.terms("name").field("resellers.name") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.subAggregation( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.reverseNested("reseller_to_product") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;); </td> 
 </tr> 
 </tbody> 
</table>

#### 2、Use aggregation response ####

### 6)、Children Aggregation(子聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 7)、Terms Aggregation(条件聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### Order(true升序，false降序) ###

#### 1、按照分组字段的数量排序 ####

#### 2、按照分组字段的照字母顺序排序 ####

#### 3、按照聚合名称标识进行排序 ####

### 8)、Significant Terms Aggregation(子条件聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 9)、Range Aggregation(范围聚合) ###

#### 1、Prepare aggregation request ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> AggregationBuilder aggregation = &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.range("agg") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.field("height") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedTo(1.0f) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // from -infinity to 1.0 (excluded) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addRange(1.0f, 1.5f) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // from 1.0 to 1.5 (excluded) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedFrom(1.5f); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // from 1.5 to +infinity </td> 
 </tr> 
 </tbody> 
</table>

#### 2、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.range.Range; // sr is here your SearchResponse object Range agg = sr.getAggregations().get("agg"); &nbsp; // For each entry for (Range.Bucket entry : agg.getBuckets()) { &nbsp;&nbsp;&nbsp;&nbsp;String key = entry.getKeyAsString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Range as key &nbsp;&nbsp;&nbsp;&nbsp;Number from = (Number) entry.getFrom(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Bucket from &nbsp;&nbsp;&nbsp;&nbsp;Number to = (Number) entry.getTo(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Bucket to &nbsp;&nbsp;&nbsp;&nbsp;long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;// Doc count &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], from [{}], to [{}], doc_count [{}]", key, from, to, docCount); } </td> 
 </tr> 
 </tbody> 
</table>

#### 3、result ####

### 10)、Date Range Aggregation(日期范围聚合) ###

#### 1、Prepare aggregation request ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> AggregationBuilder aggregation = &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.dateRange("agg") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.field("dateOfBirth") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.format("yyyy") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedTo("1950") &nbsp;&nbsp;&nbsp; // from -infinity to 1950 (excluded) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addRange("1950", "1960") &nbsp; // from 1950 to 1960 (excluded) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedFrom("1960"); // from 1960 to +infinity &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

#### 2、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.range.Range; // sr is here your SearchResponse object Range agg = sr.getAggregations().get("agg"); &nbsp; // For each entry for (Range.Bucket entry : agg.getBuckets()) { // Date range as key String key = entry.getKeyAsString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Date bucket from as a Date DateTime fromAsDate = (DateTime) entry.getFrom(); &nbsp;&nbsp; // Date bucket to as a Date DateTime toAsDate = (DateTime) entry.getTo(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Doc count long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], from [{}], to [{}], doc_count [{}]", key, fromAsDate, toAsDate, docCount); } </td> 
 </tr> 
 </tbody> 
</table>

#### 3、result ####

### 11)、IP Range Aggregation(IP范围聚合) ###

#### 1、Prepare aggregation request ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> AggregatorBuilder&lt;?&gt; aggregation = &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AggregationBuilders &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.ipRange("agg") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.field("ip") // from -infinity to 192.168.1.0 (excluded) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedTo("192.168.1.0") // from 192.168.1.0 to&nbsp;192.168.2.0(excluded)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .addRange("192.168.1.0", "192.168.2.0") &nbsp;&nbsp;&nbsp; // from 192.168.2.0 to +infinity &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.addUnboundedFrom("192.168.2.0"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </td> 
 </tr> 
 </tbody> 
</table>

#### 2、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.range.Range; // sr is here your SearchResponse object Range agg = sr.getAggregations().get("agg"); &nbsp; // For each entry for (Range.Bucket entry : agg.getBuckets()) { // Ip range as key String key = entry.getKeyAsString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Ip bucket from as a String String fromAsString = entry.getFromAsString(); &nbsp; // Ip bucket to as a String String toAsString = entry.getToAsString(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Doc count long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], from [{}], to [{}], doc_count [{}]", key, fromAsString, toAsString, docCount); } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

#### 3、result ####

Result 2:

### 12)、Histogram Aggregation(柱状图聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

### 13)、Date Histogram Aggregation(日期柱状图聚合) ###

#### 1、Prepare aggregation request ####

如果想获取最近十天的数据（相对时间）：

#### 2、Use aggregation response ####

#### 3、result ####

### 14)、Geo Distance Aggregation(地理距离聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.range.Range; // sr is here your SearchResponse object Range agg = sr.getAggregations().get("agg"); &nbsp; // For each entry for (Range.Bucket entry : agg.getBuckets()) { &nbsp;&nbsp;&nbsp;&nbsp;String key = entry.getKeyAsString(); &nbsp;&nbsp;&nbsp;// key as String &nbsp;&nbsp;&nbsp;&nbsp;Number from = (Number) entry.getFrom(); // bucket from value &nbsp;&nbsp;&nbsp;&nbsp;Number to = (Number) entry.getTo(); &nbsp;&nbsp;&nbsp;&nbsp;// bucket to value &nbsp;&nbsp;&nbsp;&nbsp;long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;// Doc count &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], from [{}], to [{}], doc_count [{}]", key, from, to, docCount); } </td> 
 </tr> 
 </tbody> 
</table>

#### 3、result ####

### 15) 、Geo Hash Grid Aggregation(地理哈希网格聚合) ###

#### 1、Prepare aggregation request ####

#### 2、Use aggregation response ####

<table style="border-collapse:collapse; border-spacing:0px; max-width:100%; color:rgb(69,69,69); font-family:&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,SimHei,Arial,SimSun; font-size:16px"> 
 <tbody style=""> 
 <tr style=""> 
 <td style=""> import org.elasticsearch.search.aggregations.bucket.geogrid.GeoHashGrid; // sr is here your SearchResponse object GeoHashGrid agg = sr.getAggregations().get("agg"); &nbsp; // For each entry for (GeoHashGrid.Bucket entry : agg.getBuckets()) { &nbsp;&nbsp;&nbsp;&nbsp;String keyAsString = entry.getKeyAsString(); // key as String &nbsp;&nbsp;&nbsp;&nbsp;GeoPoint key = (GeoPoint) entry.getKey(); &nbsp;&nbsp;&nbsp;// key as geo point &nbsp;&nbsp;&nbsp;&nbsp;long docCount = entry.getDocCount(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Doc count &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;logger.info("key [{}], point {}, doc_count [{}]", keyAsString, key, docCount); } </td> 
 </tr> 
 </tbody> 
</table>

#### 3、result ####

## 3、[Pipeline Aggregations][](管道聚合) ##

## 4、[Matrix Aggregations][](矩阵聚合) ##

[Caching heavy aggregations][]

[Returning only aggregation results][]

[Aggregation Metadata][]

[Returning the type of the aggregation][]

文章来源：[http://blog.csdn.net/it\_lihongmin/article/details/78447001][http_blog.csdn.net_it_lihongmin_article_details_78447001]

[Metrics Aggregations]: https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-metrics.html
[Bucket Aggregations]: https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-bucket.html
[Pipeline Aggregations]: https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-pipeline.html
[Matrix Aggregations]: https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-matrix.html
[Caching heavy aggregations]: https://www.elastic.co/guide/en/elasticsearch/reference/current/caching-heavy-aggregations.html
[Returning only aggregation results]: https://www.elastic.co/guide/en/elasticsearch/reference/current/returning-only-agg-results.html
[Aggregation Metadata]: https://www.elastic.co/guide/en/elasticsearch/reference/current/agg-metadata.html
[Returning the type of the aggregation]: https://www.elastic.co/guide/en/elasticsearch/reference/current/returning-aggregation-type.html
[http_blog.csdn.net_it_lihongmin_article_details_78447001]: http://blog.csdn.net/it_lihongmin/article/details/78447001