Hi Marco,
In the ideal setup, enrichment data existing in external databases is
bootstrapped into the streaming job via Flink's State Processor API, and any
follow-up changes to the enrichment data is streamed into the job as a
second union input on the enrichment operator.
For this solution to
Hi everybody,
I am brainstorming how it might be possible to perform database enrichment
with the DataStream API, use keyed state for caching, and also utilize
Async IO.
Since AsyncIO does not support keyed state, then is it possible to use an
Iterative Stream that uses keyed state for caching
