Hi,
I am using hazelcast 3.5.2 in my application and distinct aggregation throwing following exception
java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry cannot be cast to com.hazelcast.query.impl.QueryableEntry
at com.hazelcast.map.impl.proxy.MapProxyImpl.aggregate(MapProxyImpl.java:673)
at com.hazelcast.map.impl.proxy.MapProxyImpl.aggregate(MapProxyImpl.java:644)
my query :
Supplier<String, SampleEntity, String> typeExtractor = Supplier.all((value) -> value.getType());
Supplier<String, SampleEntity, String> supplier = Supplier.fromPredicate(sql, typeExtractor);
Aggregation<String, String, Set<String>> aggregate = Aggregations.distinctValues();
Set<String> distinctValues = (Set<String>)map.aggregate(supplier , aggregate);
i tried with 3.6.1 and i see following exception -
com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry cannot be cast to com.hazelcast.query.impl.Extractable
Can you help me ? Thanks.
-
Anil