Я работал над проектом потоковой обработки, который обрабатывал входящие данные с использованием метода скользящего окна в Apache Storm (v1.1.0).
Я попытался изобразить проблему, которая у меня есть на картинке ниже. Позволь мне объяснить. e1, e2, e3, e4, e5, e6, e7, e8 - это мои события, которые приходят в Apache Storm в порядке времени. w1, w2, w3 и т. д. представляют имя окна.
- Между [0,5] происходят события
- Между [5,10] происходят события
- Между [10,15] нет событий
- Между [15,20] нет событий
- Между [20,25] нет событий
- Между [25,30] происходит событие
- Между [30,25] происходит событие
В качестве вывода Apache Storm создает w1, w2, w3, w6 windows, но не создает w4 и w5
Проблема в том, что мне нужна w4 и w5 для моей логики. Что я могу сделать для этого. Я хочу получить окно, даже если нет события для окна
