我正在尝试对按某些条件过滤的值执行聚合。我也使用 Spring Data 的 ElasticSearchTemplate.query() 方法执行查询并在结果提取器中获取结果。
我正确地获得了命中(即应用了过滤器并且仅检索与这些值匹配的文档。)。但是,会对所有文档执行聚合。我认为聚合应该仅应用于过滤后的值。以下是我正在使用的代码:
SearchQuery query = //get the query
SearchResponse hits = template.query(query, new ResultsExtractor<SearchResponse>() {
@Override
public SearchResponse extract(SearchResponse response) {
return response;
}
});
为了进一步调试问题,我编写了执行查询的代码,而不是使用 spring 数据。以下是代码:
SearchRequestBuilder builder = esSetup.client().prepareSearch("document");
builder.setQuery(QueryBuilders.filteredQuery(QueryBuilders.matchAllQuery(), query.getFilter()));
builder.addFields(query.getFields().toArray(new String[query.getFields().size()]));
for(AbstractAggregationBuilder aggregation : query.getAggregations()){
builder.addAggregation(aggregation);
}
SearchResponse response = builder.get();
令我惊讶的是,这个查询执行正确,并且过滤器也应用于聚合。为了进一步分析,我浏览了elasticsearchtemplate的代码,发现它使用了setPostFilter
设置过滤器的方法。然后我修改了代码以这种方式设置过滤器:
SearchRequestBuilder builder = esSetup.client().prepareSearch("document");
// builder.setQuery(QueryBuilders.filteredQuery(QueryBuilders.matchAllQuery(), query.getFilter()));
builder.setPostFilter(query.getFilter());
builder.addFields(query.getFields().toArray(new String[query.getFields().size()]));
for(AbstractAggregationBuilder aggregation : query.getAggregations()){
builder.addAggregation(aggregation);
}
SearchResponse response = builder.get();
当我执行上面的代码时,它显示了与 spring 数据相同的行为! (即过滤器应用于查询但不应用于聚合。
这是spring data es的bug吗?如果没有,那么我是否应该使用其他方法来按照我想要的方式检索数据?
提前致谢。