Class and Description |
---|
DispatcherBootstrap
An interface containing the logic of bootstrapping the
Dispatcher of a cluster. |
DispatcherFactory
Dispatcher factory interface. |
DispatcherGateway
Gateway for the Dispatcher component.
|
DispatcherId
Fencing token of the
Dispatcher . |
ExecutionGraphInfoStore
Interface for a
ExecutionGraphInfo store. |
PartialDispatcherServices
Partial
DispatcherServices services container which needs to be completed before being
given to the Dispatcher . |
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
Class and Description |
---|
Dispatcher
Base class for the Dispatcher component.
|
Dispatcher.ExecutionType
Enum to distinguish between initial job submission and re-submission for recovery.
|
DispatcherBootstrap
An interface containing the logic of bootstrapping the
Dispatcher of a cluster. |
DispatcherBootstrapFactory
A factory to create a
DispatcherBootstrap . |
DispatcherException
Base class for
Dispatcher related exceptions. |
DispatcherFactory
Dispatcher factory interface. |
DispatcherGateway
Gateway for the Dispatcher component.
|
DispatcherId
Fencing token of the
Dispatcher . |
DispatcherOperationCaches
Encapsulates caches for results of asynchronous operations triggered by the
Dispatcher . |
DispatcherServices
Dispatcher services container. |
ExecutionGraphInfoStore
Interface for a
ExecutionGraphInfo store. |
HistoryServerArchivist
Writer for an
ExecutionGraphInfo . |
JobDispatcherFactory
DispatcherFactory which creates a MiniDispatcher . |
JobManagerMetricGroupFactory
Factory interface for
JobManagerMetricGroup . |
JobManagerRunnerFactory
Factory for a
JobManagerRunner . |
JobManagerRunnerRegistry
JobManagerRunner collects running jobs represented by JobManagerRunner . |
JobMasterServiceLeadershipRunnerFactory
Factory which creates a
JobMasterServiceLeadershipRunner . |
MiniDispatcher
Mini Dispatcher which is instantiated as the dispatcher component by the
JobClusterEntrypoint . |
PartialDispatcherServices
Partial
DispatcherServices services container which needs to be completed before being
given to the Dispatcher . |
PartialDispatcherServicesWithJobPersistenceComponents
DispatcherFactory services container. |
SessionDispatcherFactory
DispatcherFactory which creates a StandaloneDispatcher . |
StandaloneDispatcher |
TriggerSavepointMode
Describes the context of taking a savepoint: Whether it is a savepoint for a running job or
whether the job is cancelled, suspended or terminated with a savepoint.
|
VoidHistoryServerArchivist
No-op implementation of the
HistoryServerArchivist . |
Class and Description |
---|
DispatcherServices
Dispatcher services container. |
JobManagerRunnerRegistry
JobManagerRunner collects running jobs represented by JobManagerRunner . |
Class and Description |
---|
Dispatcher
Base class for the Dispatcher component.
|
DispatcherFactory
Dispatcher factory interface. |
DispatcherGateway
Gateway for the Dispatcher component.
|
DispatcherId
Fencing token of the
Dispatcher . |
PartialDispatcherServices
Partial
DispatcherServices services container which needs to be completed before being
given to the Dispatcher . |
Class and Description |
---|
ExecutionGraphInfoStore
Interface for a
ExecutionGraphInfo store. |
Class and Description |
---|
ExecutionGraphInfoStore
Interface for a
ExecutionGraphInfo store. |
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
TriggerSavepointMode
Describes the context of taking a savepoint: Whether it is a savepoint for a running job or
whether the job is cancelled, suspended or terminated with a savepoint.
|
Class and Description |
---|
DispatcherGateway
Gateway for the Dispatcher component.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.