Package | Description |
---|---|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.dispatcher.cleanup |
Modifier and Type | Class and 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. |
Modifier and Type | Method and Description |
---|---|
JobManagerRunnerRegistry |
OnMainThreadJobManagerRunnerRegistry.getWrappedDelegate()
Returns the delegated
JobManagerRunnerRegistry . |
Constructor and Description |
---|
Dispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobs,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
DispatcherServices dispatcherServices,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
ResourceCleanerFactory resourceCleanerFactory) |
MiniDispatcher(RpcService rpcService,
DispatcherId fencingToken,
DispatcherServices dispatcherServices,
JobGraph jobGraph,
JobResult recoveredDirtyJob,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
ResourceCleanerFactory resourceCleanerFactory,
ClusterEntrypoint.ExecutionMode executionMode) |
OnMainThreadJobManagerRunnerRegistry(JobManagerRunnerRegistry delegate,
ComponentMainThreadExecutor mainThreadExecutor) |
Constructor and Description |
---|
DispatcherResourceCleanerFactory(Executor cleanupExecutor,
RetryStrategy retryStrategy,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
JobGraphWriter jobGraphWriter,
BlobServer blobServer,
HighAvailabilityServices highAvailabilityServices,
JobManagerMetricGroup jobManagerMetricGroup) |
DispatcherResourceCleanerFactory(JobManagerRunnerRegistry jobManagerRunnerRegistry,
DispatcherServices dispatcherServices) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.