public interface TestingJobManagerLike extends FlinkActor
Modifier and Type | Method and Description |
---|---|
boolean |
checkIfAllVerticesRunning(JobID jobID) |
boolean |
checkIfAllVerticesRunningOrFinished(JobID jobID) |
boolean |
disconnectDisabled() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handle incoming messages
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleTestingMessage() |
void |
notifyListeners(JobID jobID) |
scala.Option<akka.actor.Cancellable> |
periodicCheck() |
void |
postStop() |
boolean |
postStopEnabled() |
void |
shutdown()
No killing of the VM for testing.
|
scala.collection.mutable.HashMap<JobID,scala.Tuple2<Object,scala.collection.immutable.Set<akka.actor.ActorRef>>> |
waitForAccumulatorUpdate() |
scala.collection.mutable.HashMap<JobID,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForAllVerticesToBeRunning() |
scala.collection.mutable.HashMap<JobID,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForAllVerticesToBeRunningOrFinished() |
scala.collection.mutable.HashMap<JobID,scala.collection.mutable.HashMap<JobStatus,scala.collection.immutable.Set<akka.actor.ActorRef>>> |
waitForJobStatus() |
scala.collection.mutable.HashSet<akka.actor.ActorRef> |
waitForLeader() |
scala.collection.mutable.PriorityQueue<scala.Tuple2<Object,akka.actor.ActorRef>> |
waitForNumRegisteredTaskManagers() |
scala.collection.mutable.HashSet<akka.actor.ActorRef> |
waitForShutdown() |
scala.collection.mutable.HashMap<String,scala.collection.immutable.Set<akka.actor.ActorRef>> |
waitForTaskManagerToBeTerminated() |
decorateMessage, log, receive
scala.collection.mutable.HashMap<JobID,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForAllVerticesToBeRunning()
scala.collection.mutable.HashMap<String,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForTaskManagerToBeTerminated()
scala.collection.mutable.HashMap<JobID,scala.collection.immutable.Set<akka.actor.ActorRef>> waitForAllVerticesToBeRunningOrFinished()
scala.Option<akka.actor.Cancellable> periodicCheck()
scala.collection.mutable.HashMap<JobID,scala.collection.mutable.HashMap<JobStatus,scala.collection.immutable.Set<akka.actor.ActorRef>>> waitForJobStatus()
scala.collection.mutable.HashMap<JobID,scala.Tuple2<Object,scala.collection.immutable.Set<akka.actor.ActorRef>>> waitForAccumulatorUpdate()
scala.collection.mutable.HashSet<akka.actor.ActorRef> waitForLeader()
scala.collection.mutable.PriorityQueue<scala.Tuple2<Object,akka.actor.ActorRef>> waitForNumRegisteredTaskManagers()
scala.collection.mutable.HashSet<akka.actor.ActorRef> waitForShutdown()
boolean disconnectDisabled()
boolean postStopEnabled()
void postStop()
postStop
in interface akka.actor.Actor
scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
FlinkActor
handleMessage
in interface FlinkActor
scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleTestingMessage()
boolean checkIfAllVerticesRunning(JobID jobID)
boolean checkIfAllVerticesRunningOrFinished(JobID jobID)
void notifyListeners(JobID jobID)
void shutdown()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.