я запутался в связи с отношением между эвакуаторами мерцания и нетерпеливо оцененными оконными функциями, такими как AggregateFunction и ReduceFunction,
AggregateFunction
ReduceFunction
Из документации: (https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#evictors)
Evictor имеет возможность удалять элементы из окна после срабатывания триггера и до и / или после применения оконной функции
звучит так, будто эвиктор НЕ стремится, тогда каково поведение эвиктора с AggregateFunction? Есть ли момент времени, когда все элементы назначены в окне в ОЗУ?
Спасибо
Внимание! Указание evictor предотвращает любую предварительную агрегацию, поскольку все элементы окна должны быть переданы в evictor перед применением вычислений.
я пропустил эту строку мерцания,