Class | Description |
---|---|
AkkaUtils |
This class contains utility functions for akka.
|
AkkaUtils$ |
This class contains utility functions for akka.
|
FlinkUntypedActor |
Base class for Flink's actors implemented with Java.
|
RemoteAddressExtension | |
RemoteAddressExtension$ | |
RemoteAddressExtensionImplementation |
ActorSystem Extension used to obtain the Address on which the
given ActorSystem is listening. |
Enum | Description |
---|---|
ListeningBehaviour |
Defines the listening behaviour of the JobClientActor and thus the messages
which are sent from the JobManger to the JobClientActor.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.