Способ установить время отправки данных в Kinesis Analytics, например, каждые 5 минут

Question

Я действительно смущен тем, как работает аналитика кинезиса и кинезиса.

Мне нужно отправить некоторые данные в аналитику kenisis, а затем первые десять историй (данные) должны отправляться в лямбда-функцию каждые 5 минут. У меня есть поток Kinesis, а также аналитика Kinesis, настроенная следующим образом:

Теперь проблема в том, что когда данные поступают в аналитику, кинезис-аналитика направляет истории прямо в лямбду, а это не то, чего я хочу. Мне нужно отправлять данные каждые 5 минут. Есть ли способ установить время отправки данных в Kinesis Analytics? Любая идея?

Answer 1

Вот как я это исправил:

FLOOR(("TRENDING_STORIES_001".ROWTIME - TIMESTAMP  '1970-01-01 00:00:00') SECOND / 40 TO SECOND)