Изменение размера окна \ размера прыжка в приложении KStream с раздвижными окнами - PullRequest
0 голосов
/ 29 сентября 2019

У меня есть приложение KStream, которое работает некоторое время и создает агрегаты, используя функцию скользящего окна (1-часовое окно с 10-минутным переходом).

Интересно, что произойдет, если я изменю переходsize ...

  • Могу ли я просто развернуть его с изменением перехода окна, и KStream будет знать, как с ним справиться?
  • Будет ли он начинать агрегацию со смещения, на которое он в данный момент указывает?(тогда это означает, что у меня будет частичное изображение в течение часа или около того - в соответствии с размером окна)
  • Что будет с данными в разделе журнала изменений?он останется там до тех пор, пока не истечет настроенное время хранения?
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...