Hi Maxim,
I think Ken's approach is a good idea. However, you would need to a add a
stateful operator to join the results of the individual queries if that is
needed.
In order to join the results, you would need a unique id on which you can
keyBy() to collect all 20 records that originated from th
Hi Maxim,
If reducing latency is the goal, then option #1 seems better.
Though you’d need additional logic inside of your AsyncFunction to run all 20
queries in parallel.
I’d also consider a third option...
Use a FlatMapFunction to create 20 copies of the event (assuming it’s not
large), with
