Uses of Interface
org.apache.flink.runtime.dispatcher.JobManagerRunnerRegistry

Packages that use JobManagerRunnerRegistry

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup

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

Classes in org.apache.flink.runtime.dispatcher that implement JobManagerRunnerRegistry

Modifier and Type	Class	Description
class	DefaultJobManagerRunnerRegistry	DefaultJobManagerRunnerRegistry is the default implementation of the JobManagerRunnerRegistry interface.
class	OnMainThreadJobManagerRunnerRegistry	OnMainThreadJobManagerRunnerRegistry implements JobManagerRunnerRegistry guarding the passed JobManagerRunnerRegistry instance in a way that it only allows modifying methods to be executed on the component's main thread.

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

Modifier and Type	Method	Description
JobManagerRunnerRegistry	OnMainThreadJobManagerRunnerRegistry.getWrappedDelegate()	Returns the delegated JobManagerRunnerRegistry.

Constructors in org.apache.flink.runtime.dispatcher with parameters of type JobManagerRunnerRegistry

Constructor	Description
Dispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobs, DispatcherBootstrapFactory dispatcherBootstrapFactory, DispatcherServices dispatcherServices, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory)
MiniDispatcher(RpcService rpcService, DispatcherId fencingToken, DispatcherServices dispatcherServices, ExecutionPlan executionPlan, JobResult recoveredDirtyJob, DispatcherBootstrapFactory dispatcherBootstrapFactory, JobManagerRunnerRegistry jobManagerRunnerRegistry, ResourceCleanerFactory resourceCleanerFactory, ClusterEntrypoint.ExecutionMode executionMode)
OnMainThreadJobManagerRunnerRegistry(JobManagerRunnerRegistry delegate, ComponentMainThreadExecutor mainThreadExecutor)

Uses of JobManagerRunnerRegistry in org.apache.flink.runtime.dispatcher.cleanup

Constructors in org.apache.flink.runtime.dispatcher.cleanup with parameters of type JobManagerRunnerRegistry

Constructor	Description
DispatcherResourceCleanerFactory(Executor cleanupExecutor, RetryStrategy retryStrategy, JobManagerRunnerRegistry jobManagerRunnerRegistry, ExecutionPlanWriter executionPlanWriter, BlobServer blobServer, HighAvailabilityServices highAvailabilityServices, JobManagerMetricGroup jobManagerMetricGroup)
DispatcherResourceCleanerFactory(JobManagerRunnerRegistry jobManagerRunnerRegistry, DispatcherServices dispatcherServices)