Невозможно агрегировать бесконечный поток при использовании пользовательской метки времени для окна с переключениями в Kinesis Data Analytics - PullRequest
Новая
       3

Невозможно агрегировать бесконечный поток при использовании пользовательской метки времени для окна с переключениями в Kinesis Data Analytics

0 голосов
/ 03 мая 2020

В документации, предоставленной AWS, они приводят примеры выполнения переворачивания и скольжения windows на основе ROWTIME, который является отметкой времени, когда Amazon Kinesis Analytics вставлял строку в первый поток в приложении.

Приведенный пример:

Откидное окно 

GROUP BY Ticker_Symbol, 
         STEP("INCOMING_STREAM".ROWTIME BY INTERVAL '60' SECOND);

Я хочу использовать свою собственную временную метку для выполнения этого окна. В моем случае это поле называется «recordTimeStamp».

Я определил его как метку времени: 

CREATE OR REPLACE STREAM "INCOMING_STREAM" (
    "uniqueId" INTEGER,
    "speed" INTEGER,
    "bezettingsgraad" INTEGER,
    "recordTimestamp" TIMESTAMP);

При просмотре «INCOMING_STREAM» я вижу формат метки времени, например. 2020-05-03 20:18:36.0.

Однако при переписывании вышеприведенных операторов для работы с моим собственным «recordTimestamp» я получаю сообщение:

Невозможно агрегировать бесконечный поток: предложение GROUP BY не указано или не содержит однообразных c выражений.

акробатическое окно 

GROUP BY Ticker_Symbol, 
         STEP("INCOMING_STREAM"."recordTimestamp" BY INTERVAL '60' SECOND);

Как это исправить или возможно указывает, что мое поле "recordTimestamp" монотонно увеличивается

...