Re: flink 填补窗口问题

2020-09-15 文章 Congxian Qiu
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

Re: flink 填补窗口问题

2020-09-15 文章 marble.zh...@coinflex.com.INVALID
可以补吗? 比如我现在是1分钟的窗口,要是这一分种 没有message,那就以上一个窗口的数据作为这一窗口的数据。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink 填补窗口问题

2020-09-10 文章 marble.zh...@coinflex.com.INVALID
大家好, flink第二个窗口无数据时,怎么填充第一个窗口数据;flink是以事件为驱动,这种需求能实现吗?通过状态可以保存上一个窗口数据吗? -- Sent from: http://apache-flink.147419.n8.nabble.com/