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

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 :
All article :

I founded it in the DataSet API but not in the DataStream API !


Can some one explain to me who to solve this problem ?

Thanks a lot.

Flinkly regards,

View raw message