Hello
does beam have support for something similar to
KeyedBroadcastProcessFunction which exists in flink?
I am looking for an option to have broadcast state in beam so it can be
shared between different operators
Thanks
Sigalit
Thanks for your response.
The use case is 2 pipelines:
A. receives information from kafka and "holds" that info
B. a pipeline which is triggered by a scheduler and every x minutes should
send the info i received in pipeline A to another kafka topic
Currently these pipelines are implemented by BEAM
