Да. Похоже, шторм поддерживает скользящее окно на основе счета. Apache Flink также поддерживает это. Хотите знать, почему поток Kafka не поддерживает это.
еализовать агрегацию (или преобразование) скользящего окна с помощью окна с фиксированным размером?
Например, если у меня есть потоковые данные, подобные следующим
input stream = 1,2,3,4,5,6,7,8...
Предположим, что время здесь не имеет значения. И скажем, моя агрегатная функция - СРЕДНЯЯ, а размер окна установлен на 3 записи (не 3 миллисекунды, 3 секунды, 3 часа и т. Д.), Я хотел бы, чтобы мой выходной поток был
output stream = avg(1,2,3), avg(2,3,4), avg(3,4,5), avg(4,5,6), avg(5,6,7)... = 2,3,4,5,6...
Windows, документированная в работе потоков Kafka, «основана на времени». Даже конструктор базового класса Window имеет следующую подпись:
Window(long startMs, long endMs)
Поэтому я не был уверен, что это правильный инструментне основанный на времени агрегация окон.
Apache Flink поддерживаетраздвижные и опрокидывающиеся окна, Это именно то, что мне нужно, но я ищу похожую функцию в Kafka Streams.