flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Use Flink's actor system
Date Sun, 16 Jul 2017 18:11:33 GMT
Hello,

I don't think the actor system is exposed to operators in any way.

If you want to access it whatever it may take (reflection etc.) you 
could try working your way through the metric group (through the runtime 
context) into the MetricRegistry and from the into the MetricQueryService.

Regards,
Chesnay

On 12.07.2017 17:05, Lorenzo Affetti wrote:
> 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
>
>
>
>


Mime
View raw message