我想运行以下查询
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)
(另外:我认为这并不等同于现在我可能得到的是retract stream而不是append stream)
暂无答案!
目前还没有任何答案,快来回答吧!