java - 使用 SqlPredicate 聚合时出现 Hazelcast 错误

Question

我正在尝试使用 SqlPredicate 谓词在 Hazelcast 中的 map 上执行搜索和聚合。当像下面这样搜索时，SqlPredicate 工作得很好:

imap = //get map from Hazelcast
Collection c = imap.values(new SqlPredicate("field=value"));

但是，如果我尝试执行以下聚合，则会收到 ClassCastException:

imap = //get map from Hazelcast

PropertyExtractor<-,-> pe = x -> x.getValue();
SqlPredicate p = new SqlPredicate("field=value");

Supplier<-,-,-> s = Supplier.fromPredicate(p, Supplier.all(pe));
int x = imap.aggregate(s, Aggregations.integerMax());

我还尝试创建自己的自定义谓词，它是 SqlPredicate 的包装器:

public static MyPredicate implements Predicate<-,-> {
    private SqlPredicate pred;

    public MyPredicate(String s){
        pred = new SqlPredicate(s);
    }

    @Override
    public boolean apply(Entry<-,-> arg0){
        return pred.apply(arg0);
    }
}

这会导致 NullPointerException，并且永远不会到达 apply() 方法。

这是 Hazelcast 中的错误吗？或者是否存在 SqlPredicate 不能用于创建供应商的原因？ SqlPredicate 实现了 Predicate 接口(interface)，所以我认为它应该可以工作。

我目前在搜索时使用 SqlPredicate，因此我希望能够在聚合时使用相同的谓词进行过滤。

Answer 1

当前聚合内部不支持 SqlPredicates(以及 Predicates/PredicateBuilder predicates)。但是，您可以为此类简单的调用实现自己的谓词。据我所知，我猜它会在 3.6 中得到修复。