所有程序包的分层结构

程序包分层结构:

• org.apache.flink.yarn,
• org.apache.flink.yarn.cli,
• org.apache.flink.yarn.configuration,
• org.apache.flink.yarn.entrypoint,
• org.apache.flink.yarn.executors

类分层结构

• java.lang.Object
  • org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory<ClusterID> (implements org.apache.flink.client.deployment.ClusterClientFactory<ClusterID>)
    • org.apache.flink.yarn.YarnClusterClientFactory
  • org.apache.flink.client.cli.AbstractCustomCommandLine (implements org.apache.flink.client.cli.CustomCommandLine)
    • org.apache.flink.yarn.cli.FlinkYarnSessionCli
  • org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<ClusterID,ClientFactory> (implements org.apache.flink.core.execution.PipelineExecutor)
    • org.apache.flink.yarn.executors.YarnJobClusterExecutor
  • org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor<ClusterID,ClientFactory> (implements org.apache.flink.core.execution.PipelineExecutor)
    • org.apache.flink.yarn.executors.YarnSessionClusterExecutor
  • org.apache.flink.runtime.resourcemanager.ActiveResourceManagerFactory<T> (implements org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<T>)
    • org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory
  • org.apache.flink.runtime.entrypoint.ClusterEntrypoint (implements org.apache.flink.util.AutoCloseableAsync, org.apache.flink.runtime.rpc.FatalErrorHandler)
    • org.apache.flink.runtime.entrypoint.JobClusterEntrypoint
      • org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint
    • org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint
      • org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint
  • org.apache.flink.runtime.rpc.RpcEndpoint (implements org.apache.flink.util.AutoCloseableAsync, org.apache.flink.runtime.rpc.RpcGateway)
    • org.apache.flink.runtime.rpc.FencedRpcEndpoint<F>
      • org.apache.flink.runtime.resourcemanager.ResourceManager<WorkerType> (implements org.apache.flink.runtime.leaderelection.LeaderContender, org.apache.flink.runtime.resourcemanager.ResourceManagerGateway)
        • org.apache.flink.runtime.resourcemanager.ActiveResourceManager<WorkerType>
          • org.apache.flink.yarn.YarnResourceManager (implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler, org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler)
  • org.apache.flink.yarn.Utils
  • org.apache.flink.yarn.cli.YarnApplicationStatusMonitor (implements java.lang.AutoCloseable)
  • org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever (implements org.apache.flink.yarn.YarnClusterInformationRetriever)
  • org.apache.flink.yarn.YarnClusterDescriptor (implements org.apache.flink.client.deployment.ClusterDescriptor<T>)
  • org.apache.flink.yarn.YarnConfigKeys
  • org.apache.flink.yarn.configuration.YarnConfigOptions
  • org.apache.flink.yarn.configuration.YarnConfigOptionsInternal
  • org.apache.flink.yarn.entrypoint.YarnEntrypointUtils
  • org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory (implements org.apache.flink.core.execution.PipelineExecutorFactory)
  • org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory (implements org.apache.flink.core.execution.PipelineExecutorFactory)
  • org.apache.flink.yarn.YarnTaskExecutorRunner
  • org.apache.flink.yarn.YarnWorkerNode (implements org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable)

接口分层结构

• org.apache.flink.yarn.YarnClusterInformationRetriever

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.yarn.configuration.YarnConfigOptions.UserJarInclusion