Окно сеанса, как рассчитать разрыв? - PullRequest
0 голосов
/ 08 июля 2020

Я пытаюсь понять эту схему оконного сеанса:

введите описание изображения здесь

Как я понял, у нас есть четыре события:

  1. 12: 00: 00 - событие началось в это время

  2. 12: 00: 25 - другое событие завершилось

  3. 12: 00: 30 - событие началось в это время

  4. 12: 00:50 - закончилось другое событие

Как нам получить разрыв в 15 секунд?

Не могли бы вы объяснить, что такое начало / конец - это одно событие или два разных ?

1 Ответ

1 голос
/ 09 июля 2020

У событий нет времени начала или окончания, а есть только одна скалярная метка времени события.

Если вы используете сеанс windows, события, разница во времени между которыми меньше, чем промежуток параметр, попадают в одно окно.

Таким образом, начало и конец окна сеанса всегда соответствуют событию.

Обратите внимание, что сеанс windows не предназначен для случая, когда вы выделите начальные / конечные события во входном потоке. Рассматривает сеанс windows скорее как сценарий «обнаружения сеанса», т. Е. У вас нет сеансов во входном потоке, и вы хотите распределить входные данные по сеансам на основе временных меток записи.

Проверьте документы для более подробной информации: https://docs.confluent.io/current/streams/developer-guide/dsl-api.html#session - windows

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...