flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ladhari Sadok <laadhari.sa...@gmail.com>
Subject Broadcast to all the other operators
Date Wed, 08 Nov 2017 22:25:31 GMT
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

Mime
View raw message