Apache Flink - время между событиями - PullRequest
0 голосов
/ 17 ноября 2018

Я начинаю экспериментировать с Apache Flink и достиг некоторых очень простых вещей.Теперь я с нетерпением жду возможности выяснить разницу во времени между последовательными элементами.

Моя идея состояла в том, чтобы использовать countWindowAll (2) в потоке, чтобы я мог оценивать окна с двумя последовательными событиями.Однако я не понимаю, как я могу получить доступ к временным меткам двух событий в окне, чтобы сгенерировать / отобразить это на разницу во времени.

Есть ли у кого-нибудь хорошая ссылка или даже пример кода для чего?Я пытаюсь достичь?

Ларс

...