Uses of Class
org.apache.flink.runtime.dispatcher.DispatcherServices
-
Packages that use DispatcherServices Package Description org.apache.flink.runtime.dispatcher org.apache.flink.runtime.dispatcher.cleanup -
-
Uses of DispatcherServices in org.apache.flink.runtime.dispatcher
Methods in org.apache.flink.runtime.dispatcher that return DispatcherServices Modifier and Type Method Description static DispatcherServicesDispatcherServices. from(PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents, JobManagerRunnerFactory jobManagerRunnerFactory, CleanupRunnerFactory cleanupRunnerFactory)Constructors in org.apache.flink.runtime.dispatcher with parameters of type DispatcherServices Constructor Description Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices)Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory)StandaloneDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices) -
Uses of DispatcherServices in org.apache.flink.runtime.dispatcher.cleanup
Constructors in org.apache.flink.runtime.dispatcher.cleanup with parameters of type DispatcherServices Constructor Description DispatcherResourceCleanerFactory(JobManagerRunnerRegistry jobManagerRunnerRegistry, DispatcherServices dispatcherServices)
-