Hierarchy For Package org.apache.flink.runtime.dispatcher

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.util.AbstractID (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.runtime.dispatcher.DispatcherId
  • org.apache.flink.runtime.dispatcher.FileArchivedExecutionGraphStore (implements org.apache.flink.runtime.dispatcher.ArchivedExecutionGraphStore)
  • org.apache.flink.runtime.dispatcher.JobDispatcherFactory (implements org.apache.flink.runtime.dispatcher.DispatcherFactory<T>)
  • org.apache.flink.runtime.dispatcher.MemoryArchivedExecutionGraphStore (implements org.apache.flink.runtime.dispatcher.ArchivedExecutionGraphStore)
  • org.apache.flink.runtime.rest.RestServerEndpoint (implements org.apache.flink.util.AutoCloseableAsync)
    • org.apache.flink.runtime.webmonitor.WebMonitorEndpoint<T> (implements org.apache.flink.runtime.webmonitor.history.JsonArchivist, org.apache.flink.runtime.leaderelection.LeaderContender)
      • org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
  • 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.dispatcher.Dispatcher (implements org.apache.flink.runtime.dispatcher.DispatcherGateway, org.apache.flink.runtime.leaderelection.LeaderContender, org.apache.flink.runtime.jobmanager.SubmittedJobGraphStore.SubmittedJobGraphListener)
        • org.apache.flink.runtime.dispatcher.MiniDispatcher
        • org.apache.flink.runtime.dispatcher.StandaloneDispatcher
  • org.apache.flink.runtime.dispatcher.SingleJobSubmittedJobGraphStore (implements org.apache.flink.runtime.jobmanager.SubmittedJobGraphStore)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.flink.util.FlinkException
        • org.apache.flink.runtime.dispatcher.DispatcherException

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.runtime.dispatcher.ArchivedExecutionGraphStore
• org.apache.flink.runtime.dispatcher.DispatcherFactory<T>
• org.apache.flink.runtime.dispatcher.HistoryServerArchivist
• org.apache.flink.runtime.dispatcher.JobManagerRunnerFactory
• org.apache.flink.runtime.rpc.RpcGateway
  • org.apache.flink.runtime.rpc.FencedRpcGateway<F>
    • org.apache.flink.runtime.dispatcher.DispatcherGateway (also extends org.apache.flink.runtime.webmonitor.RestfulGateway)
  • org.apache.flink.runtime.webmonitor.RestfulGateway
    • org.apache.flink.runtime.dispatcher.DispatcherGateway (also extends org.apache.flink.runtime.rpc.FencedRpcGateway<F>)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.runtime.dispatcher.SessionDispatcherFactory (implements org.apache.flink.runtime.dispatcher.DispatcherFactory<T>)
    • org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory (implements org.apache.flink.runtime.dispatcher.JobManagerRunnerFactory)
    • org.apache.flink.runtime.dispatcher.VoidHistoryServerArchivist (implements org.apache.flink.runtime.dispatcher.HistoryServerArchivist)