Hazelcast聚合API导致带有谓词的ClassCastException

Question

public class Report implements Portable, Comparable<Report>, Serializable 
{
    private String id;
    private String name;
    private String sourceId;
    private Date timestamp;
    private Map<String,Object> payload;
  // ...
}

IMap<String, Report> reportMap = hazelcast.getMap("reports");
reportMap.addIndex("sourceId", false);

我一直在尝试使用聚合框架按sourceid对报告进行计数。尝试1：

  public static int reportCountforSource(String sourceId) 
  {
      EntryObject e = new PredicateBuilder().getEntryObject();
      Predicate<String, Report> predicate = e.get("sourceId").equal(sourceId);
      Supplier<String, Report, Object> supplier = Supplier.fromPredicate(predicate);
      Long count = reportMap.aggregate(supplier, Aggregations.count());

      return count.intValue();
  }    

这导致聚合框架抛出ClassCastException:

Caused by: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.SupplierConsumingMapper$SimpleEntry cannot be cast to com.hazelcast.query.impl.QueryableEntry
    at com.hazelcast.query.Predicates$AbstractPredicate.readAttribute(Predicates.java:859) 
    at com.hazelcast.query.Predicates$EqualPredicate.apply(Predicates.java:779) 
    at com.hazelcast.mapreduce.aggregation.impl.PredicateSupplier.apply(PredicateSupplier.java:58) 
    at com.hazelcast.mapreduce.aggregation.impl.SupplierConsumingMapper.map(SupplierConsumingMapper.java:55)
    at com.hazelcast.mapreduce.impl.task.KeyValueSourceMappingPhase.executeMappingPhase(KeyValueSourceMappingPhase.java:49)

然后更改为使用谓词而不是PredicateBuilder().GetEntryObject()进行尝试#2:

  public static int reportCountforSource(String sourceId) 
  {
      @SuppressWarnings("unchecked")
      Predicate<String, Report> predicate = Predicates.equal("sourceId", sourceId);
      Supplier<String, Report, Object> supplier = Supplier.fromPredicate(predicate);
      Long count = reportMap.aggregate(supplier, Aggregations.count());

      return count.intValue();
  }    

最后，我在尝试#3中使用了lambda来实现谓词接口：

  public static int reportCountforSource(String sourceId) 
  {
      Predicate<String, Report> predicate = (entry) ->  entry.getValue().getSourceId().equals(sourceId);
      Supplier<String, Report, Object> supplier = Supplier.fromPredicate(predicate);
      Long count = reportMap.aggregate(supplier, Aggregations.count());

      return count.intValue();
  }    

这一尝试终于奏效了。

问题1：这是Hazelcast的一个bug吗？似乎聚合框架应该支持由谓词或谓词构建器构建的谓词？如果不是，那么应该创建一个新的类型（例如，aggregationpredicate)来避免这种混淆。

问题2（与问题1相关）：使用lambda谓词会导致我创建的索引未被使用。相反，映射中的每个条目都被反序列化，以确定它是否与谓词匹配，这会大大减慢运行速度。是否有任何方法可以从使用索引的谓词创建供应商？（编辑：通过在readportable方法中放置一个计数器，我验证了每个条目都被反序列化）。

Answer 1

这看起来像榛子虫。我想我从来没有创建过unittest来测试PredicateBuilder创建的谓词。你能在GitHub上提交一个问题吗？

当前mapreduce上不支持索引，无论您尝试什么。索引系统将在不久的将来重写，以支持所有类型的非原语索引，如partial或stuff。

另一个尚不具备的是针对可移植对象的优化读取器，它将防止完全反序列化。