diff options
Diffstat (limited to 'modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java')
-rw-r--r-- | modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java b/modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java index 956f953da1..dd469e2131 100644 --- a/modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java +++ b/modules/aggs-matrix-stats/src/main/java/org/elasticsearch/search/aggregations/support/MultiValuesSourceAggregatorFactory.java @@ -24,6 +24,7 @@ import org.elasticsearch.search.aggregations.AggregatorFactories; import org.elasticsearch.search.aggregations.AggregatorFactory; import org.elasticsearch.search.aggregations.InternalAggregation.Type; import org.elasticsearch.search.aggregations.pipeline.PipelineAggregator; +import org.elasticsearch.search.internal.SearchContext; import java.io.IOException; import java.util.HashMap; @@ -36,8 +37,8 @@ public abstract class MultiValuesSourceAggregatorFactory<VS extends ValuesSource protected Map<String, ValuesSourceConfig<VS>> configs; public MultiValuesSourceAggregatorFactory(String name, Type type, Map<String, ValuesSourceConfig<VS>> configs, - AggregationContext context, AggregatorFactory<?> parent, AggregatorFactories.Builder subFactoriesBuilder, - Map<String, Object> metaData) throws IOException { + SearchContext context, AggregatorFactory<?> parent, AggregatorFactories.Builder subFactoriesBuilder, + Map<String, Object> metaData) throws IOException { super(name, type, context, parent, subFactoriesBuilder, metaData); this.configs = configs; } @@ -48,7 +49,7 @@ public abstract class MultiValuesSourceAggregatorFactory<VS extends ValuesSource HashMap<String, VS> valuesSources = new HashMap<>(); for (Map.Entry<String, ValuesSourceConfig<VS>> config : configs.entrySet()) { - VS vs = context.valuesSource(config.getValue(), context.searchContext()); + VS vs = config.getValue().toValuesSource(context); if (vs != null) { valuesSources.put(config.getKey(), vs); } |