动态生成统计窗口与取消-慕课网

1回答

Michael_PK 2020-07-20 16:42:23

在flink中大部分场景都是根据时间相关的比如eventime等来生成窗口的，你的需要如果不是按照这种类似的时间的话，那很大可能需要自定义实现了，这个就比较麻烦了

0 回复有任何疑惑可以回复我~

提问者村姑的诱惑 #1

是使用eventTime，但是希望可以通过外部参数来控制window size。而且希望可以动态的控制统计任务是否运行

回复有任何疑惑可以回复我~ 2020-07-20 16:47:41

提问者村姑的诱惑 #2

比如，通过kafka向计算引擎下达命令，让计算引擎通过命令中的某些参数去动态生成一个滚动窗口来统计。当然也可以通过kafka的命令下达来让计算引擎取消一个滚动窗口的统计

回复有任何疑惑可以回复我~ 2020-07-20 16:53:06

Michael_PK 回复提问者村姑的诱惑 #3

flink自带的要么根据时间长度，要么根据计数的，要是不满足这两个只能自定义window的触发条件去实现

回复有任何疑惑可以回复我~ 2020-07-20 17:54:40

动态生成统计窗口与取消