Использует ли быстрый агрегатор или реактивный двигатель Hazelcast ранее агрегированный результат?

Question

Мы планируем использовать быстрый агрегатор или струю газа.У нас есть требование к агрегированию на основе бесконечного потока мессенга.Допустим, скажем, если я получу сообщение того же типа, будет ли оно кэшировать ранее агрегированные данные, или будет рассчитываться на основе всех предыдущих сообщений этого типа, например, скажем, нам нужно агрегировать оценки студента и ключа, являющегося идентификатором студента, у нас есть тема Кафки, гдеидут непрерывные сообщения, сопровождающие студенческий билет, знаки и некоторые другие детали.Теперь предположим, что мы получаем 4 сообщения ученика 1,

1, 90 - вывод 90 2,80 - 170 3, 70 - 240 4 100- 370

Вв этом случае каждый раз, когда мы получаем сообщение, кэш-программа jetelcast кэширует последний агрегированный результат или каждый раз агрегирует все сообщения

Answer 1

@ Абхишек, ты можешь сделать оба пути. Существуют агрегатные операции, которые вы можете выполнять над подмножеством данных непрерывно, с помощью окон или вы можете использовать скользящие агрегирующие операции, которые будут выполнять агрегацию для каждого элемента и переносить предыдущие результаты.

Пожалуйста, посмотрите примеры здесь:

• Для оконной агрегации: 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