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.yarn.AbstractYarnClusterDescriptor (implements org.apache.flink.client.deployment.ClusterDescriptor<ClientType>)
- 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.client.program.ClusterClient
- 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.RegisteredYarnWorkerNode (implements org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable)
- 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)
- akka.actor.UntypedActor (implements akka.actor.Actor)
- org.apache.flink.yarn.Utils
- org.apache.flink.yarn.YarnApplicationMasterRunner
- org.apache.flink.yarn.YarnConfigKeys
- org.apache.flink.yarn.YarnContainerInLaunch (implements org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable)
- 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.LocalGetYarnMessage$ (implements scala.Product, scala.Serializable)
- org.apache.flink.yarn.YarnMessages.LocalStopYarnSession (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.TriggerApplicationClientRegistration (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$
- org.apache.flink.yarn.YarnResourceManagerCallbackHandler (implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler)
- org.apache.flink.yarn.YarnTaskManager$
- org.apache.flink.yarn.YarnTaskManagerRunner
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.