1

我正在尝试对按某些条件过滤的值执行聚合。我正在使用弹簧数据的 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 data es的错误吗？如果不是，那么，是否有任何其他方法可以用来以我想要的方式检索数据？

提前致谢。

4

1 回答 1

8

这种行为是 Elasticsearch 设计的。

简而言之，聚合和后置过滤器的输入是与query请求正文部分匹配的文档集。因此，聚合不会应用于过滤后的文档。

但是，如果您确实希望在过滤后的文档上应用聚合，请“将过滤器移动到query部分内”，即使用过滤查询。现在该query部分的输出将是过滤后的文档集，并且聚合将按预期应用于它们。

因此，根据您的要求，请使用过滤查询而不是后过滤器。

于 2015-02-01T14:20:03.097 回答