У меня есть 4 сценария ios, относящиеся к скольжению windows. Мы ведем подсчет и идентификатор входящих событий, если они имеют определенный c тип, и запускаем окно процесса, если этот счет достигает определенного значения c.
Давайте предположим, что мы используем время обработки в качестве характеристики времени c. Определенное окно имеет размер 8 часов с слайдом 4 часа. В случае, если приложение не работает в течение 10 минут, когда приложение перезапускается, будет ли окно оставаться активным? Если да, как flink связывает состояние с конкретным окном? Или мы потеряем активное значение windows?
Для того же случая, если мы должны были рассмотреть обработку, основанную на времени события, Если приложение было go выключено в течение 10 минут, все активные windows будут доступны после перезапуска? Или они будут потеряны и новые windows будут созданы входящими событиями?
Мы поддерживаем флаг в окне процесса, используя глобальное состояние. Содержится ли содержимое контрольной точки глобального состояния? Сможем ли мы получить доступ к состоянию флага непосредственно перед выключением?
Мы определяем несколько оконных операторов в нашей топологии и направляем события каждому, фильтруя их. В такой ситуации, если активные windows доступны во время перезапуска, как windows будет связан с правильным оператором? Будет ли он использовать идентификатор оператора?