LAST_VALUE над окном в FlinkSQL - PullRequest
Новая
       13

LAST_VALUE над окном в FlinkSQL

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

Я хотел бы выполнить следующий запрос 

SELECT key, LAST_VALUE(value) OVER (PARTITION BY key ORDER BY ts) AS value
  FROM [table]
 GROUP BY key, TUMBLE(ts, INTERVAL '5' MINUTE)

Я ожидал бы, что LAST_VALUE вернет последнее значение каждого временного окна. Вместо этого я получаю 

 Expression 'value' is not being grouped

Есть идеи, как это решить?

Редактировать 1: Пробовал что-то вроде 

SELECT key, LAST_VALUE(value) OVER (PARTITION BY key, TUMBLE(ts, INTERVAL '5' MINUTE) ORDER BY ts) AS value
  FROM [table]

, но вместо этого получил 

Unsupported call: TUMBLE(TIMESTAMP(3) *ROWTIME*, INTERVAL SECOND(3) NOT NULL)

(также: я думаю, что это не эквивалентно, поскольку теперь я, вероятно, получаю поток возврата вместо потока добавления)

...