現(xiàn)有索引數(shù)據(jù)：

index:school

type:student

---------------------------------------------------

{"grade":"1", "class":"1", "name":"xiao 1"}

{"grade":"1", "class":"1", "name":"xiao 2"}

{"grade":"1", "class":"2", "name":"xiao 3"}

{"grade":"1", "class":"2", "name":"xiao 4"}

{"grade":"1", "class":"2", "name":"xiao 5"}

Java分組統(tǒng)計(jì)年級(jí)和班級(jí)學(xué)生個(gè)數(shù)，如SQL: SELECT grade,class,count(1) FROM student GROUP BY grade,class;

package test;

import java.util.Iterator;

import java.util.Map;

import org.elasticsearch.action.search.SearchRequestBuilder;

import org.elasticsearch.action.search.SearchResponse;

import org.elasticsearch.action.search.SearchType;

import org.elasticsearch.search.aggregations.Aggregation;

import org.elasticsearch.search.aggregations.AggregationBuilders;

import org.elasticsearch.search.aggregations.bucket.terms.StringTerms;

import org.elasticsearch.search.aggregations.bucket.terms.Terms.Bucket;

import org.elasticsearch.search.aggregations.bucket.terms.TermsBuilder;

import org.junit.Test;

import utils.NesUtils;

public class TestAggregation

{

@Test

public void testAggregation()

{

SearchRequestBuilder srb = NesUtils.getSearcher("school");

srb.setTypes("student");

srb.setSearchType(SearchType.COUNT);

TermsBuilder gradeTermsBuilder = AggregationBuilders.terms("gradeAgg").field("grade");

TermsBuilder classTermsBuilder = AggregationBuilders.terms("classAgg").field("class");

gradeTermsBuilder.subAggregation(classTermsBuilder);

srb.addAggregation(gradeTermsBuilder);

SearchResponse sr = srb.execute().actionGet();

Map aggMap = sr.getAggregations().asMap();

StringTerms gradeTerms = (StringTerms) aggMap.get("gradeAgg");

Iterator gradeBucketIt = gradeTerms.getBuckets().iterator();

while(gradeBucketIt.hasNext())

{

Bucket gradeBucket = gradeBucketIt.next();

System.out.println(gradeBucket.getKey() + "年級(jí)有" + gradeBucket.getDocCount() +"個(gè)學(xué)生。");

StringTerms classTerms = (StringTerms) gradeBucket.getAggregations().asMap().get("classAgg");

Iterator classBucketIt = classTerms.getBuckets().iterator();

while(classBucketIt.hasNext())

{

Bucket classBucket = classBucketIt.next();

System.out.println(gradeBucket.getKey() + "年級(jí)" +classBucket.getKey() + "班有" + classBucket.getDocCount() +"個(gè)學(xué)生。");

}

System.out.println();

}

}

}

運(yùn)行完成輸出結(jié)果

---------------------------------------------------

1年級(jí)有5個(gè)學(xué)生。

1年級(jí)2班有3個(gè)學(xué)生。

1年級(jí)1班有2個(gè)學(xué)生。

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的elasticsearch group by java_java elasticsearch聚合查询实例详解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。