TestingJobManagerLike
This mixin can be used to decorate a JobManager with messages for testing purpose.
|
TestingJobManagerMessages.AllVerticesRunning$ |
TestingJobManagerMessages.DisablePostStop$
|
TestingJobManagerMessages.ExecutionGraphFound$ |
TestingJobManagerMessages.ExecutionGraphNotFound$ |
TestingJobManagerMessages.JobStatusIs$ |
TestingJobManagerMessages.NotifyListeners$ |
TestingJobManagerMessages.NotifyWhenAccumulatorChange$ |
TestingJobManagerMessages.NotifyWhenAtLeastNumTaskManagerAreRegistered$ |
TestingJobManagerMessages.NotifyWhenJobRemoved$ |
TestingJobManagerMessages.NotifyWhenJobStatus$ |
TestingJobManagerMessages.NotifyWhenLeader$
|
TestingJobManagerMessages.NotifyWhenTaskManagerTerminated$ |
TestingJobManagerMessages.RequestExecutionGraph$ |
TestingJobManagerMessages.RequestSavepoint$ |
TestingJobManagerMessages.RequestWorkingTaskManager$ |
TestingJobManagerMessages.ResponseExecutionGraph |
TestingJobManagerMessages.ResponseSavepoint$ |
TestingJobManagerMessages.TaskManagerTerminated$ |
TestingJobManagerMessages.UpdatedAccumulators$ |
TestingJobManagerMessages.WaitForAllVerticesToBeRunning$ |
TestingJobManagerMessages.WaitForAllVerticesToBeRunningOrFinished$ |
TestingJobManagerMessages.WorkingTaskManager$ |
TestingJobManagerMessages$ |
TestingMessages.Alive$ |
TestingMessages.CheckIfJobRemoved$ |
TestingMessages.ComponentShutdown$ |
TestingMessages.DisableDisconnect$ |
TestingMessages.NotifyOfComponentShutdown$ |
TestingMessages$ |
TestingTaskManagerLike
This mixin can be used to decorate a TaskManager with messages for testing purposes.
|
TestingTaskManagerMessages.AccumulatorsChanged$ |
TestingTaskManagerMessages.JobManagerTerminated$ |
TestingTaskManagerMessages.NotifyWhenJobManagerTerminated$ |
TestingTaskManagerMessages.NotifyWhenRegisteredAtJobManager$ |
TestingTaskManagerMessages.NotifyWhenTaskIsRunning$ |
TestingTaskManagerMessages.NotifyWhenTaskRemoved$ |
TestingTaskManagerMessages.RegisterSubmitTaskListener$ |
TestingTaskManagerMessages.RequestBroadcastVariablesWithReferences$ |
TestingTaskManagerMessages.RequestNumActiveConnections$ |
TestingTaskManagerMessages.RequestRunningTasks$ |
TestingTaskManagerMessages.ResponseBroadcastVariablesWithReferences$ |
TestingTaskManagerMessages.ResponseNumActiveConnections$ |
TestingTaskManagerMessages.ResponseRunningTasks$ |
TestingTaskManagerMessages.ResponseSubmitTaskListener$ |
TestingTaskManagerMessages$
|