springdata elasticsearch aggregation 操作

这段日子在搞 springdata 操作 elasticsearch 其中使用聚合操作，特此一记：

下面是https://github.com/spring-projects/spring-data-elasticsearch/tree/5.x 的spring-data-elasticsearch 项目的：ElasticsearchTemplateAggregationTests代码：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:elasticsearch-template-test.xml")
public class ElasticsearchTemplateAggregationTests {public static final String RIZWAN_IDREES = "Rizwan Idrees";public static final String MOHSIN_HUSEN = "Mohsin Husen";public static final String JONATHAN_YAN = "Jonathan Yan";public static final String ARTUR_KONCZAK = "Artur Konczak";public static final int YEAR_2002 = 2002;public static final int YEAR_2001 = 2001;public static final int YEAR_2000 = 2000;@Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;@Beforepublic void before() {elasticsearchTemplate.deleteIndex(ArticleEntity.class);elasticsearchTemplate.createIndex(ArticleEntity.class);elasticsearchTemplate.putMapping(ArticleEntity.class);elasticsearchTemplate.refresh(ArticleEntity.class);IndexQuery article1 = new ArticleEntityBuilder("1").title("article four").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addAuthor(JONATHAN_YAN).score(10).buildIndex();IndexQuery article2 = new ArticleEntityBuilder("2").title("article three").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addPublishedYear(YEAR_2000).score(20).buildIndex();IndexQuery article3 = new ArticleEntityBuilder("3").title("article two").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(30).buildIndex();IndexQuery article4 = new ArticleEntityBuilder("4").title("article one").subject("accounting").addAuthor(RIZWAN_IDREES).addPublishedYear(YEAR_2002).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(40).buildIndex();elasticsearchTemplate.index(article1);elasticsearchTemplate.index(article2);elasticsearchTemplate.index(article3);elasticsearchTemplate.index(article4);elasticsearchTemplate.refresh(ArticleEntity.class);}@Testpublic void shouldReturnAggregatedResponseForGivenSearchQuery() {// givenSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchAllQuery()).withSearchType(SearchType.DEFAULT).withIndices("test-index-articles").withTypes("article").addAggregation(terms("subjects").field("subject")).build();// whenAggregations aggregations = elasticsearchTemplate.query(searchQuery, new ResultsExtractor<Aggregations>() {@Overridepublic Aggregations extract(SearchResponse response) {return response.getAggregations();}});//

// Aggregations 只是获得了结果，没有取出数据；以及这样的实例；

assertThat(aggregations, is(notNullValue())); assertThat(aggregations.asMap().get("subjects"), is(notNullValue()));}}

其实上面代码使用 restful 方式的拼写为：

GET test-index-articles/article/_search
{"size": 0, "aggs": {"my_aggs_hehe": {"terms": {"field": "subject"}}}
}

以及返回的结果：

{"took": 231,"timed_out": false,"_shards": {"total": 1,"successful": 1,"failed": 0},"hits": {"total": 4,"max_score": 0,"hits": []},"aggregations": {"my_aggs_hehe": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "computing","doc_count": 3},{"key": "accounting","doc_count": 1}]}}
}


那么我经过使用 java 的 debug 模式查看生成的类：


于是我将代码写如下：

@Testpublic void shouldReturnAggregatedResponseForGivenSearchQuery() {// givenSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(matchAllQuery()).withSearchType(SearchType.DEFAULT).withIndices("test-index-articles").withTypes("article").addAggregation(terms("subjects").field("subject")).build();// whenAggregations aggregations = elasticsearchTemplate.query(searchQuery, new ResultsExtractor<Aggregations>() {@Overridepublic Aggregations extract(SearchResponse response) {return response.getAggregations();}});Map<String, Aggregation> map=aggregations.asMap();for(String s:map.keySet()){StringTerms a=(StringTerms) map.get(s);List<Terms.Bucket> list=a.getBuckets();for(Terms.Bucket b:list){System.out.println("key is "+ b.getKeyAsString()+"---and value is "+ b.getDocCount());}}// thenassertThat(aggregations, is(notNullValue()));assertThat(aggregations.asMap().get("subjects"), is(notNullValue()));}

于是结果为：

key is computing---and value is 3
key is accounting---and value is 1

springdata elasticsearch aggregation 操作相关推荐

Elasticsearch安装操作步骤
Elasticsearch安装操作步骤操作步骤 1,下载elasticsearch 2,上传到linux环境 3,安装及配置 4,es后台启动操作步骤 1,下载elasticsearch http ...
Elasticsearch RestHighLevelClient操作
RestHighLevelClient操作 <dependency><groupId>org.elasticsearch.client</groupId><a ...
Spring Data ElasticSearch的操作
依赖 <dependency><groupId>org.springframework.boot< ...
Elasticsearch高级操作
文章目录一.高级javaAPI操作 1.统计每个球队当中球员的数量 2.统计每个球队中每个位置的球员数量 3.分组求各种值 4.统计每个球队年龄最小值 5.分组求平均值 6.分组求和 7.聚合排序 ...
elasticsearch简单操作（二）
让我们建立一个员工目录,假设我们刚好在Megacorp工作,这时人力资源部门出于某种目的需要让我们创建一个员工目录,这个目录用于促进人文关怀和用于实时协同工作,所以它有以下不同的需求: 1.数据能够包 ...
Elasticsearch Aggregation 多个字段分组统计 Java API实现
2019独角兽企业重金招聘Python工程师标准>>> 现有索引数据: index:school type:student ----------------------------- ...
elasticsearch聚合操作——本质就是针对搜索后的结果使用桶bucket（允许嵌套）进行group by，统计下分组结果，包括min/max/avg...
分析最后,我们还有一个需求需要完成:允许管理者在职员目录中进行一些分析. Elasticsearch有一个功能叫做聚合(aggregations),它允许你在数据上生成复杂的分析统计.它很像SQL中 ...
python连接es数据库_Python Elasticsearch API操作ES集群
环境Centos 7.4 Python 2.7 Pip 2.7 MySQL-python 1.2.5 Elasticsearc 6.3.1 Elasitcsearch6.3.2 知识点调用Python ...
Elasticsearch Java 操作client
0.题记之前Elasticsearch的应用比较多,但大多集中在关系型.非关系型数据库与Elasticsearch之间的同步.以上内容完成了Elasticsearch所需要的基础数据量的供给.但想要 ...
SpringData ElasticSearch入门案例
导入需要的依赖坐标 <dependencies><dependency><groupId>org.elasticsearch</groupId>< ...

springdata elasticsearch aggregation 操作

springdata elasticsearch aggregation 操作相关推荐

最新文章

热门文章