HI, I have just started to explore Flink and have couple of questions. I am wondering if its possible to call a rest endpoint asynchronously and pipe the response to the next state of my transformation on the stream. The idea is such that after charging my data in a predefined time window, I would like to apply some algorithm/transformation on the window of data external to Flink. The algos have been exposed as REST endpoints.
My seconds question is an extension to the previous one, if i need to transform my window data by applying three different algorithms in parallel exposed via subsequent rest endpoints, how do wait unless the individual rest endpoints respond back . Potentially I need to join the results of the three algorithms before I call the sink. Regards, Vijay Raajaa
