Hi Averell,
thank you for your answer. Indeed it is what I did. And it worked just
fine in this case. I am sure I'll be facing mor complex scenarios, so it'd
be very interesting to hear more about what you try to achieve by using
broadcast state.
Regards
On Thu, Feb 21, 2019 at 11:36 AM Averell
Hi Artur,
Is that possible to make that "static" stream a keyedStream basing on that
foreign key?
If yes, then just connect the two streams, keyed on that foreign key. In the
CoProcessFunction, for every single record from the static stream, you write
its content into a ValueState; and for every r
Hi,
I have a stream of buildings and each building has foreign key reference to
municipality. Municipalities data set is quite static. Both are placed on
Kafka topics. I want to enrich each building with municipality name.
FLIP 17, proposal would be ideal for this use case but it's still just a
pr
