Uses of Class
org.apache.flink.runtime.dispatcher.Dispatcher

Packages that use Dispatcher

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.entrypoint.component

Uses of Dispatcher in org.apache.flink.runtime.dispatcher

Classes in org.apache.flink.runtime.dispatcher with type parameters of type Dispatcher

Modifier and Type	Interface and Description
interface	DispatcherFactory<T extends Dispatcher> Dispatcher factory interface.

Subclasses of Dispatcher in org.apache.flink.runtime.dispatcher

Modifier and Type	Class and Description
class	MiniDispatcher Mini Dispatcher which is instantiated as the dispatcher component by the JobClusterEntrypoint.
class	StandaloneDispatcher Dispatcher implementation which spawns a JobMaster for each submitted JobGraph within in the same process.

Methods in org.apache.flink.runtime.dispatcher that return Dispatcher

Modifier and Type

Method and Description

Dispatcher

SessionDispatcherFactory.createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist)

Uses of Dispatcher in org.apache.flink.runtime.entrypoint.component

Classes in org.apache.flink.runtime.entrypoint.component with type parameters of type Dispatcher

Modifier and Type	Class and Description
class	AbstractDispatcherResourceManagerComponentFactory<T extends Dispatcher,U extends RestfulGateway> Abstract class which implements the creation of the DispatcherResourceManagerComponent components.
class	DispatcherResourceManagerComponent<T extends Dispatcher> Component which starts a Dispatcher, ResourceManager and WebMonitorEndpoint in the same process.
interface	DispatcherResourceManagerComponentFactory<T extends Dispatcher> Factory for the DispatcherResourceManagerComponent.

Methods in org.apache.flink.runtime.entrypoint.component that return types with arguments of type Dispatcher

Modifier and Type	Method and Description
protected DispatcherResourceManagerComponent<Dispatcher>	SessionDispatcherResourceManagerComponentFactory.createDispatcherResourceManagerComponent(Dispatcher dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type Dispatcher

Modifier and Type	Method and Description
protected DispatcherResourceManagerComponent<Dispatcher>	SessionDispatcherResourceManagerComponentFactory.createDispatcherResourceManagerComponent(Dispatcher dispatcher, ResourceManager<?> resourceManager, LeaderRetrievalService dispatcherLeaderRetrievalService, LeaderRetrievalService resourceManagerRetrievalService, WebMonitorEndpoint<?> webMonitorEndpoint, JobManagerMetricGroup jobManagerMetricGroup)

Constructor parameters in org.apache.flink.runtime.entrypoint.component with type arguments of type Dispatcher

Constructor and Description
SessionDispatcherResourceManagerComponentFactory(DispatcherFactory<Dispatcher> dispatcherFactory, ResourceManagerFactory<?> resourceManagerFactory)