Use Flink's actor system

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Use Flink's actor system

affo
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