Hi,
unfortunately, there is no direct and easy API for this, but it seems
worthwhile having this in the future. Nevertheless, I can see two ways of doing
this with low effort in Flink:
1. The cleanest way I could think of: implement your own multiplexing in the
source. At first, the source wil
Hey all-
I'm using the Managed Key State to store data in a map. I would
like, on initial job startup (trigged by a config), for that state to
be populated before processing begings. This can either be from
another stream or from a file. In Samza, one would do this with
bootstrap streams
(htt
