【发布时间】:2019-08-20 15:51:45
【问题描述】:
使用 Window Tumbling 时如何从流中选择最后一条记录?
我找不到任何 KSQL 函数。
我想实现如下目标:
SELECT
max(charge) AS maxCharge,
last(charge) AS lastCharge
FROM charge_stream
WINDOW TUMBLING (SIZE 1 MINUTES)
GROUP BY deviceID
除了 last 不是一个有效的 KSQL 函数。
【问题讨论】:
标签: apache-kafka ksqldb