Class Hierarchy
- java.lang.Object
- scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
- scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
- scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
- org.apache.flink.runtime.jobmanager.JobManager (implements org.apache.flink.runtime.FlinkActor, org.apache.flink.runtime.leaderelection.LeaderContender, org.apache.flink.runtime.LeaderSessionMessageFilter, org.apache.flink.runtime.LogMessages, org.apache.flink.runtime.jobmanager.SubmittedJobGraphStore.SubmittedJobGraphListener)
- org.apache.flink.runtime.jobmanager.MemoryArchivist (implements org.apache.flink.runtime.FlinkActor, org.apache.flink.runtime.LogMessages)
- org.apache.flink.runtime.taskmanager.TaskManager (implements org.apache.flink.runtime.FlinkActor, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalListener, org.apache.flink.runtime.LeaderSessionMessageFilter, org.apache.flink.runtime.LogMessages)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.AllVerticesRunning (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.DisablePostStop$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.ExecutionGraphFound (implements scala.Product, scala.Serializable, org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.ResponseExecutionGraph)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.ExecutionGraphNotFound (implements scala.Product, scala.Serializable, org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.ResponseExecutionGraph)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.JobStatusIs (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyListeners$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenAccumulatorChange (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenAtLeastNumTaskManagerAreRegistered (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenJobRemoved (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenJobStatus (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenLeader$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.NotifyWhenTaskManagerTerminated (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.RequestExecutionGraph (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.RequestSavepoint (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.RequestWorkingTaskManager (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.ResponseSavepoint (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.TaskManagerTerminated (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.UpdatedAccumulators (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.WaitForAllVerticesToBeRunning (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.WaitForAllVerticesToBeRunningOrFinished (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages.WorkingTaskManager (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingJobManagerMessages$
- org.apache.flink.runtime.testingUtils.TestingMessages
- org.apache.flink.runtime.testingUtils.TestingMessages.Alive$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingMessages.CheckIfJobRemoved (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingMessages.ComponentShutdown (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingMessages.DisableDisconnect$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingMessages.NotifyOfComponentShutdown$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingMessages$
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.AccumulatorsChanged (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.JobManagerTerminated (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.NotifyWhenJobManagerTerminated (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.NotifyWhenRegisteredAtJobManager (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.NotifyWhenTaskIsRunning (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.NotifyWhenTaskRemoved (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.RegisterSubmitTaskListener (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.RequestBroadcastVariablesWithReferences$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.RequestNumActiveConnections$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.RequestRunningTasks$ (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.ResponseBroadcastVariablesWithReferences (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.ResponseNumActiveConnections (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.ResponseRunningTasks (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages.ResponseSubmitTaskListener (implements scala.Product, scala.Serializable)
- org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages$
Interface Hierarchy
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.