状态引擎中似乎不支持聚合操作?

您好,请教个问题。我有个流表,需要流式做一个 groupby 之后的窗口计算,类似上图。但状态引擎中似乎不支持聚合操作,请问有没有什么办法解决这类问题?

attachments-2023-11-JtW4Fwbr6551779b80c13.png

请先 登录 后评论

1 个回答

wale

这个问题可以两个引擎级联解决。第一个聚合引擎,根据index分组,sum(val);第二个状态引擎,metric中msum(val, 2)其实就是与前值求和。

attachments-2023-11-EFboBCzf655178235b4e7.png

请先 登录 后评论