public interface TestingTaskManagerLike extends FlinkActor
Modifier and Type | Method and Description |
---|---|
boolean |
disconnectDisabled() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handler for testing related messages
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleTestingMessage() |
scala.collection.mutable.HashMap<JobID,akka.actor.ActorRef> |
registeredSubmitTaskListeners()
Map of registered task submit listeners
|
void |
shutdown()
No killing of the VM for testing.
|
scala.collection.mutable.HashSet<ExecutionAttemptID> |
unregisteredTasks() |
scala.collection.mutable.HashMap<String,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForJobManagerToBeTerminated() |
scala.collection.mutable.HashMap<akka.actor.ActorRef,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForRegisteredAtResourceManager() |
scala.collection.mutable.HashMap<ExecutionAttemptID,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForRemoval() |
scala.collection.mutable.HashMap<ExecutionAttemptID,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForRunning() |
scala.collection.mutable.HashSet<akka.actor.ActorRef> |
waitForShutdown() |
decorateMessage, log, receive
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
scala.collection.mutable.HashMap<ExecutionAttemptID,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForRemoval()
scala.collection.mutable.HashMap<String,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForJobManagerToBeTerminated()
scala.collection.mutable.HashMap<akka.actor.ActorRef,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForRegisteredAtResourceManager()
scala.collection.mutable.HashMap<ExecutionAttemptID,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForRunning()
scala.collection.mutable.HashSet<ExecutionAttemptID> unregisteredTasks()
scala.collection.mutable.HashMap<JobID,akka.actor.ActorRef> registeredSubmitTaskListeners()
scala.collection.mutable.HashSet<akka.actor.ActorRef> waitForShutdown()
boolean disconnectDisabled()
scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
handleMessage
in interface FlinkActor
scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleTestingMessage()
void shutdown()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.