您好,请教个问题。我有个流表,需要流式做一个 groupby 之后的窗口计算,类似上图。但状态引擎中似乎不支持聚合操作,请问有没有什么办法解决这类问题?
这个问题可以两个引擎级联解决。第一个聚合引擎,根据index分组,sum(val);第二个状态引擎,metric中msum(val, 2)其实就是与前值求和。