Пустые окна в Apache Flink

Question

У меня есть поток данных с временем события, возможно ли создавать окна без данных в Apache Flink?Например, с размером падающего окна 15 minutes было бы идеально, если бы я мог очистить окна, если у них нет событий в период времени, например [(0, 15), (15, 20), ...].

Answer 1

Нет, это невозможно.Оператор окна Flink создает окно только при добавлении к нему первого события.

Причина, по которой результаты для пустых окон не выдаются, заключается в том, что окна обычно определяются в потоке с ключами (без ключа в потоке невозможно обрабатывать окно параллельно).Если Flink будет выдавать записи для пустых окон в потоке с ключами, он должен будет выдавать результат для каждого возможного значения ключа.Поскольку существует слишком много возможных ключей, это невозможно.