This is an automated email from the ASF dual-hosted git repository.
jkevan pushed a commit to branch UNOMI-225-ES7
in repository https://gitbox.apache.org/repos/asf/unomi.git
The following commit(s) were added to refs/heads/UNOMI-225-ES7 by this push:
new a63894a fix aggregation cast issue ES7
a63894a is described below
commit a63894ace3fde5a0be1c7ec0eba2a0bedbd75945
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());
}
}