Flink: Как очистить состояние сразу после обработки окна с ключом?

Question

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

Может ли это быть достигнуто в методе evictorили apply метод после обработки каждого ключевого окна?

Answer 1

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