Hi Vijay,
Generally, for asynchronous operations to enrich (or in your case, fetching the
algorithm for the actual transformation of the data), you’ll want to look at
Flink’s Async I/O [1].
For your second question, I can see it as a stateful `FlatMapFunction` that
keeps the seen results as ma
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 woul
