版本号:elasticsearch5.X
/**
* 分组计算各组个数
*/
@Test
public void aggregation(){
SearchResponse response = client.prepareSearch("twitter").setTypes("tweet")
.addAggregation(AggregationBuilders.terms("countAgg").field("user.keyword"))
.get();
//输出
Terms countAgg = response.getAggregations().get("countAgg");
for (Terms.Bucket entry : countAgg.getBuckets()) {
System.out.println("user:"+entry.getKey()+"---------"+"count:"+entry.getDocCount());
}
}