Hazelcast - 支持分组的分布式查询聚合

Question

我们需要使用 Hazelcast 3.8-EA 版本查询 IMDG 示例

select sum(salary),sum(bonus),dept from Employee where birthYear > 1989 group by dept 

where 子句:: SqlPredicate("birthYear > 1989")

聚合::

1. 在员工地图上使用 Aggregators.doubleSum("salary") , Aggregators.doubleSum("bonus")
2. 或者通过扩展 AbstractAggregator

问题是如何使用内置聚合处理多个聚合以及如何处理 group by 子句？

Answer 1

尚无正式的分组支持，但您可以创建自己的 SumWithGroupBy 聚合，按照您希望的分组方式对每组的薪水和奖金求和。 您可以查看 Aggregators.doubleSum 代码以了解如何实现聚合。 这是一些手动编码，但它只是几行自定义逻辑。