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());
                         }
                     }

Reply via email to