Hi
这个需求可以考虑用 processfunction[1] 来实现,window 的 state 只能给单独的 window 使用,其他
window 不能操作之前的 window 的 state
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/process_function.html#the-keyedprocessfunction
Best,
Congxian
marble.zh...@coinflex.com.INVALID
可以补吗? 比如我现在是1分钟的窗口,要是这一分种 没有message,那就以上一个窗口的数据作为这一窗口的数据。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
大家好, flink第二个窗口无数据时,怎么填充第一个窗口数据;flink是以事件为驱动,这种需求能实现吗?通过状态可以保存上一个窗口数据吗?
--
Sent from: http://apache-flink.147419.n8.nabble.com/