Callback interface for the
Utility functions for the interaction with Akka
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.
Base class for Flink's actors implemented with Java.
The quarantine monitor subscribes to the event bus of the actor system in which it was started.
Stopping supervisor strategy which logs
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.