Uses of Class
org.apache.flink.runtime.dispatcher.Dispatcher
-
Packages that use Dispatcher Package Description org.apache.flink.runtime.dispatcher org.apache.flink.runtime.dispatcher.runner -
-
Uses of Dispatcher in org.apache.flink.runtime.dispatcher
Subclasses of Dispatcher in org.apache.flink.runtime.dispatcher Modifier and Type Class Description class
MiniDispatcher
Mini Dispatcher which is instantiated as the dispatcher component by theJobClusterEntrypoint
.class
StandaloneDispatcher
Methods in org.apache.flink.runtime.dispatcher that return Dispatcher Modifier and Type Method Description Dispatcher
DispatcherFactory. createDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents)
Create aDispatcher
. -
Uses of Dispatcher in org.apache.flink.runtime.dispatcher.runner
Methods in org.apache.flink.runtime.dispatcher.runner with parameters of type Dispatcher Modifier and Type Method Description static DefaultDispatcherGatewayService
DefaultDispatcherGatewayService. from(Dispatcher dispatcher)
-