TestingJobManager |
JobManager implementation extended by testing messages
|
TestingJobManagerMessages |
|
TestingJobManagerMessages.AllVerticesRunning |
|
TestingJobManagerMessages.AllVerticesRunning$ |
|
TestingJobManagerMessages.DisablePostStop$ |
|
TestingJobManagerMessages.ExecutionGraphFound |
|
TestingJobManagerMessages.ExecutionGraphFound$ |
|
TestingJobManagerMessages.ExecutionGraphNotFound |
|
TestingJobManagerMessages.ExecutionGraphNotFound$ |
|
TestingJobManagerMessages.JobStatusIs |
|
TestingJobManagerMessages.JobStatusIs$ |
|
TestingJobManagerMessages.NotifyListeners$ |
|
TestingJobManagerMessages.NotifyWhenAccumulatorChange |
Registers a listener to receive a message when accumulators changed.
|
TestingJobManagerMessages.NotifyWhenAccumulatorChange$ |
|
TestingJobManagerMessages.NotifyWhenAtLeastNumTaskManagerAreRegistered |
Registers to be notified by an org.apache.flink.runtime.messages.Messages.Acknowledge
message when at least numRegisteredTaskManager have registered at the JobManager.
|
TestingJobManagerMessages.NotifyWhenAtLeastNumTaskManagerAreRegistered$ |
|
TestingJobManagerMessages.NotifyWhenJobRemoved |
|
TestingJobManagerMessages.NotifyWhenJobRemoved$ |
|
TestingJobManagerMessages.NotifyWhenJobStatus |
|
TestingJobManagerMessages.NotifyWhenJobStatus$ |
|
TestingJobManagerMessages.NotifyWhenLeader$ |
|
TestingJobManagerMessages.NotifyWhenTaskManagerTerminated |
|
TestingJobManagerMessages.NotifyWhenTaskManagerTerminated$ |
|
TestingJobManagerMessages.RequestExecutionGraph |
|
TestingJobManagerMessages.RequestExecutionGraph$ |
|
TestingJobManagerMessages.RequestSavepoint |
Requests a savepoint from the job manager.
|
TestingJobManagerMessages.RequestSavepoint$ |
|
TestingJobManagerMessages.RequestWorkingTaskManager |
|
TestingJobManagerMessages.RequestWorkingTaskManager$ |
|
TestingJobManagerMessages.ResponseSavepoint |
Response to a savepoint request.
|
TestingJobManagerMessages.ResponseSavepoint$ |
|
TestingJobManagerMessages.TaskManagerTerminated |
|
TestingJobManagerMessages.TaskManagerTerminated$ |
|
TestingJobManagerMessages.UpdatedAccumulators |
Reports updated accumulators back to the listener.
|
TestingJobManagerMessages.UpdatedAccumulators$ |
|
TestingJobManagerMessages.WaitForAllVerticesToBeRunning |
|
TestingJobManagerMessages.WaitForAllVerticesToBeRunning$ |
|
TestingJobManagerMessages.WaitForAllVerticesToBeRunningOrFinished |
|
TestingJobManagerMessages.WaitForAllVerticesToBeRunningOrFinished$ |
|
TestingJobManagerMessages.WorkingTaskManager |
|
TestingJobManagerMessages.WorkingTaskManager$ |
|
TestingJobManagerMessages$ |
|
TestingMemoryArchivist |
Memory archivist extended by testing messages
|
TestingMessages |
|
TestingMessages.Alive$ |
|
TestingMessages.CheckIfJobRemoved |
|
TestingMessages.CheckIfJobRemoved$ |
|
TestingMessages.ComponentShutdown |
|
TestingMessages.ComponentShutdown$ |
|
TestingMessages.DisableDisconnect$ |
|
TestingMessages.NotifyOfComponentShutdown$ |
|
TestingMessages$ |
|
TestingTaskManager |
Subclass of the TaskManager to support testing messages
|
TestingTaskManagerMessages |
|
TestingTaskManagerMessages.AccumulatorsChanged |
Message to give a hint to the task manager that accumulator values were updated in the task.
|
TestingTaskManagerMessages.AccumulatorsChanged$ |
|
TestingTaskManagerMessages.JobManagerTerminated |
|
TestingTaskManagerMessages.JobManagerTerminated$ |
|
TestingTaskManagerMessages.NotifyWhenJobManagerTerminated |
|
TestingTaskManagerMessages.NotifyWhenJobManagerTerminated$ |
|
TestingTaskManagerMessages.NotifyWhenRegisteredAtJobManager |
|
TestingTaskManagerMessages.NotifyWhenRegisteredAtJobManager$ |
|
TestingTaskManagerMessages.NotifyWhenTaskIsRunning |
|
TestingTaskManagerMessages.NotifyWhenTaskIsRunning$ |
|
TestingTaskManagerMessages.NotifyWhenTaskRemoved |
|
TestingTaskManagerMessages.NotifyWhenTaskRemoved$ |
|
TestingTaskManagerMessages.RegisterSubmitTaskListener |
|
TestingTaskManagerMessages.RegisterSubmitTaskListener$ |
|
TestingTaskManagerMessages.RequestBroadcastVariablesWithReferences$ |
|
TestingTaskManagerMessages.RequestNumActiveConnections$ |
|
TestingTaskManagerMessages.RequestRunningTasks$ |
|
TestingTaskManagerMessages.ResponseBroadcastVariablesWithReferences |
|
TestingTaskManagerMessages.ResponseBroadcastVariablesWithReferences$ |
|
TestingTaskManagerMessages.ResponseNumActiveConnections |
|
TestingTaskManagerMessages.ResponseNumActiveConnections$ |
|
TestingTaskManagerMessages.ResponseRunningTasks |
|
TestingTaskManagerMessages.ResponseRunningTasks$ |
|
TestingTaskManagerMessages.ResponseSubmitTaskListener |
A response to a listened job ID containing the submitted task deployment descriptor.
|
TestingTaskManagerMessages.ResponseSubmitTaskListener$ |
|
TestingTaskManagerMessages$ |
|