Interface | Description |
---|---|
QuarantineHandler |
Callback interface for the
QuarantineMonitor which is called in case the actor system
has been quarantined or quarantined another system. |
Class | Description |
---|---|
AkkaUtils |
This class contains utility functions for akka.
|
AkkaUtils$ |
This class contains utility functions for akka.
|
DefaultQuarantineHandler |
Default quarantine handler which logs the quarantining events, then shuts down the given
actor system by sending Kill to all actors and then shutting the JVM down with the given
exit code.
|
FlinkUntypedActor |
Base class for Flink's actors implemented with Java.
|
QuarantineMonitor |
The quarantine monitor subscribes to the event bus of the actor system in which it was started.
|
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–2018 The Apache Software Foundation. All rights reserved.