Hello, I'm working on Rules Engine project with Flink 1.3, in this project I want to update some keyed operator state when external event occurred.
I have a Datastream of updates (from kafka) I want to broadcast the data contained in this stream to all keyed operator so I can change the state in all operators. It is like this use case : Image : https://data-artisans.com/wp-content/uploads/2017/10/streaming-in-definitions.png All article : https://data-artisans.com/blog/real-time-fraud-detection-ing-bank-apache-flink I founded it in the DataSet API but not in the DataStream API ! https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/batch/index.html#broadcast-variables Can some one explain to me who to solve this problem ? Thanks a lot. Flinkly regards, Sadok
