Hi Flavio, Not sure I understood the requirements correctly. Couldn't you just collect and bundle all records with a regular window operator and forward one record for each key-window to an AsyncIO operator?
Best, Fabian Am Do., 18. Juli 2019 um 12:20 Uhr schrieb Flavio Pompermaier < pomperma...@okkam.it>: > Hi to all, > I'm trying to exploit async IO in my Flink job. > In my use case I use keyed tumbling windows and I'd like to execute the > async action only once per key and window (while > the AsyncDataStream.unorderedWait execute the async call for every element > of my stream) ..is there an easy way to do that apart from using a process > function (that basically will lose the asynchronicity)? > > Best, > Flavio >
