Class Hierarchy
- java.lang.Object
- org.apache.flink.runtime.yarn.AbstractFlinkYarnClient
- org.apache.flink.runtime.yarn.AbstractFlinkYarnCluster
- 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.yarn.ApplicationClient (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.yarn.ApplicationClient$
- org.apache.flink.yarn.ApplicationMaster$
- org.apache.flink.yarn.ApplicationMasterBase
- org.apache.flink.yarn.ApplicationMasterBase$
- 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.yarn.RegisterApplicationMasterResponseReflector
- org.apache.flink.yarn.RegisterApplicationMasterResponseReflector$
- 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)
- java.lang.Thread (implements java.lang.Runnable)
- java.lang.Throwable (implements java.io.Serializable)
- org.apache.flink.yarn.Utils
- org.apache.flink.yarn.YarnJobManager.AMRMClientAsyncHandler (implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler)
- org.apache.flink.yarn.YarnMessages
- org.apache.flink.yarn.YarnMessages.AcknowledgeApplicationClientRegistration$ (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.ApplicationMasterStatus (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.CheckForUserCommand$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.HeartbeatWithYarn$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.JobManagerLeaderAddress (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.JobManagerStopped$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.LocalGetYarnClusterStatus$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.LocalGetYarnMessage$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.LocalStopAMAfterJob (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.LocalStopYarnSession (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.PollYarnClusterStatus$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.RegisterApplicationClient$ (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.StartYarnSession (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.StopAMAfterJob (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.StopYarnSession (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.TriggerApplicationClientRegistration (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.UnregisterClient$ (implements scala.Product, org.apache.flink.runtime.messages.RequiresLeaderSessionID, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.YarnContainersAllocated (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.YarnContainersCompleted (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.YarnMessage (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages$
- org.apache.flink.yarn.YarnTaskManagerRunner
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.