我知道流分析有几个窗口功能。在我的例子中,我需要在一个时间窗口上聚合消息,在这个窗口中,每当字段(或字段的组合)发生变化时,都应该启动一个新窗口。
为了使其具体化:假设我有以下消息:
我希望通过productType
和/或alarmX
中的更改定义的窗口进行聚合。因此,我想对项目(1,2,3) - (4,5) - (6,7) - (8,9)进行汇总。
这怎么可能使用流分析?还有别的选择吗?
发布于 2021-02-09 01:00:30
你查过会话窗口的这个吗?您还需要一些时间戳列。
https://stackoverflow.com/questions/66105344
复制相似问题