This is an automated email from the ASF dual-hosted git repository. shuber pushed a commit to branch UNOMI-225-ES7 in repository https://gitbox.apache.org/repos/asf/unomi.git
commit 34a040fc8b22413d38b2f54952f0f88fa0cbacd2 Author: Kevan <[email protected]> AuthorDate: Thu Nov 21 17:16:54 2019 +0100 fix aggregation cast issue ES7 --- .../persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java index b853367..76800c9 100644 --- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java +++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java @@ -84,6 +84,7 @@ import org.elasticsearch.search.aggregations.bucket.range.RangeAggregationBuilde import org.elasticsearch.search.aggregations.bucket.terms.IncludeExclude; import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder; import org.elasticsearch.search.aggregations.metrics.InternalNumericMetricsAggregation; +import org.elasticsearch.search.aggregations.metrics.NumericMetricsAggregation; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.search.sort.GeoDistanceSortBuilder; import org.elasticsearch.search.sort.SortBuilders; @@ -1770,7 +1771,7 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, if (metricsResults instanceof HasAggregations) { aggregations = ((HasAggregations) metricsResults).getAggregations(); for (Aggregation aggregation : aggregations) { - InternalNumericMetricsAggregation.SingleValue singleValue = (InternalNumericMetricsAggregation.SingleValue) aggregation; + NumericMetricsAggregation.SingleValue singleValue = (NumericMetricsAggregation.SingleValue) aggregation; results.put("_" + singleValue.getName(), singleValue.value()); } }
