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 |
---|---|
ActorUtils |
Utility functions for the interaction with Akka
Actor . |
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.
|
StoppingSupervisorWithoutLoggingActorKilledExceptionStrategy |
Stopping supervisor strategy which logs
ActorKilledException only on debug log level. |
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–2020 The Apache Software Foundation. All rights reserved.