Re: Broadcast state with WindowedStream

2019-03-06 Thread Aggarwal, Ajay
Still looking for ideas as to how I can use broadcast state in my use case. From: "Aggarwal, Ajay" Date: Monday, March 4, 2019 at 4:52 PM To: "user@flink.apache.org" Subject: Re: Broadcast state with WindowedStream It sort of makes sense that broadcast state i

Re: Broadcast state with WindowedStream

2019-03-04 Thread Aggarwal, Ajay
It sort of makes sense that broadcast state is not available with WindowedStream. But if I need some dynamic global state in MyProcessWindowFunction what are my options? Ajay From: "Aggarwal, Ajay" Date: Monday, March 4, 2019 at 4:36 PM To: "user@flink.apache.org" Subj

Broadcast state with WindowedStream

2019-03-04 Thread Aggarwal, Ajay
Is it possible to use broadcast state with windowing? My job looks like below inputStream .keyBy("some-key") .window(TumblingEventTimeWindows.of(Time.seconds(Properties.WINDOW_SIZE)))