Обработка и очистка описаны здесь , проще говоря, разница в том, что FIRE_AND_PURGE удаляет содержимое окна после запуска.
Все встроенные присваиватели окон Flink (включая окна сеансов)) позаботиться об очистке их содержимого, когда наступит подходящее время, т. е. после истечения допустимого опоздания.Но очистка выполняется как отдельный шаг, а не в сочетании с срабатыванием триггера.
Содержимое Windows хранится в состоянии Flink, поэтому их расположение зависит от того, какой бэкэнд состояния вы используете.Это состояние будет сохраняться в куче, если вы используете бэкэнд состояния на основе кучи, или на диске, если вы используете RocksDB.
Сохранение ваших окон в полном объеме до тех пор, пока они не будут очищены, зависит от того, используете ли вы инкрементное агрегирование - другими словами, если вы используете уменьшение, агрегирование или свертывание, то только текущий результатагрегации сохраняется, иначе это набор всех событий, назначенных окну.