hazelcast - Hazelcast 快速聚合器或喷射器是否使用先前聚合的结果

Question

我们计划使用快速聚合器或 hzc jet。我们需要基于无限的消息流进行聚合。因此，假设我收到相同类型的消息，它将缓存先前聚合的数据，或者它将根据该类型的所有先前消息进行计算，例如，假设我们必须聚合学生的标记和键是学生 ID，我们有 kafka 主题在哪里包含学生 ID 和分数以及其他一些细节的连续消息即将发布。现在假设我们收到学生 1 的 4 条消息，

1, 90 - 输出 90 2,80 - 170 3, 70 - 240 4 100- 370

在这种情况下，每次我们接收消息时，hazelcast jet 都会缓存最后的聚合结果，或者每次都会聚合所有消息

Answer 1

@Abhishek，你可以做这两种方式。您可以在数据子集上连续运行聚合操作、窗口化，或者您可以使用滚动聚合操作来对每个项目进行聚合并携带先前的结果。

请在此处查看示例：

• 对于窗口聚合：https ://github.com/hazelcast/hazelcast-jet-code-samples/blob/0.7-maintenance/sliding-windows/src/main/java/TopNStocks.java
• 对于滚动聚合：https ://github.com/hazelcast/hazelcast-jet-code-samples/blob/master/rolling-aggregation/src/main/java/TradingVolume.java