|
Hello everybody,
I want to do some experiments with communication across operators.
Even if arguable, I wondered if it is possible to directly use the clustered actor system used by Flink.
If so, how can I get an instance of the actor system in an Operator?
Thank you in advance
Lorenzo Affetti
|