时间戳

首页 > 解决方案 > 使用窗口翻转时如何从 KSQL 流中获取最后一个值

apache-kafka - 使用窗口翻转时如何从 KSQL 流中获取最后一个值

问题描述

使用 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-kafkaksqldb

解决方案

我想你要找的是LATEST_BY_OFFSET.

推荐阅读