Kinesis Analytics: определить конец подпотока - PullRequest
0 голосов
/ 21 июня 2019

Мой поток Kinesis содержит идентификаторы сеанса, и для каждого сеанса событие keepAlive отправляется каждую секунду вместе с отметкой времени.Если больше событий keepAlive сеанса не было отправлено в произвольном временном окне (скажем, 20 секунд), то больше данных из этого сеанса не поступит, и я хочу объявить, что этот сеанс завершен.Есть ли способ определить последнюю временную метку события keepAlive этого сеанса?Проблема в том, что это может произойти в любое время, поэтому я не вижу, как в этом случае могут работать ограниченные по времени окна.

Любая помощь очень ценится.Спасибо!

...