Можно ли узнать, какие элементы были выселены из окна? - PullRequest
0 голосов
/ 11 февраля 2019

В функции обработки окна можно узнать, какие элементы были выселены?

Вариант использования:

  • Окно с большим количеством событий
  • Использованиеevictor
  • Сокращение функции, которая в вычислительном отношении дорогая

Теперь, что я хотел сделать, было что-то вроде:

  1. Окно получает событие, добавляет его ксостояние
  2. Выселяет некоторые элементы
  3. "+ 1" в агрегированное значение, в соответствии с новым событием
  4. "- 1" в агрегированное значение для каждого события, выгруженного в 2

Поскольку # выселенных элементов << # элементов в окне, это будет намного эффективнее. </p>

Имеет ли это смысл?Возможно ли это?

1 Ответ

0 голосов
/ 11 февраля 2019

К вашему сведению, планируется добавить поддержку оконного API Flink для оптимизации дел с сильно перекрывающимися окнами.Вот зонтик билет в Джира .Надеюсь, это охватит ваш вариант использования.

Что касается того, что возможно сейчас, я не верю, что возможно обмениваться информацией между Evictor и ProcessWindowFunction.

...