【问题标题】:How to get last value from a KSQL stream when using window tumbling使用窗口翻转时如何从 KSQL 流中获取最后一个值
【发布时间】: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


    【解决方案1】:

    我想你要找的是LATEST_BY_OFFSET

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-10-16
      • 1970-01-01
      • 1970-01-01
      • 2021-07-11
      • 2011-01-05
      • 2020-09-09
      相关资源
      最近更新 更多