Modifier and Type | Class and Description |
---|---|
class |
KubernetesMultipleComponentLeaderElectionHaServices
Kubernetes HA services that use a single leader election service per JobManager.
|
Modifier and Type | Class and Description |
---|---|
class |
BlobServer
This class implements the BLOB server.
|
Modifier and Type | Class and Description |
---|---|
class |
SingleJobJobGraphStore
JobGraphStore implementation for a single job. |
Modifier and Type | Method and Description |
---|---|
static DefaultResourceCleaner.Builder<GloballyCleanableResource> |
DefaultResourceCleaner.forGloballyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor,
Executor cleanupExecutor,
RetryStrategy retryStrategy) |
Modifier and Type | Interface and Description |
---|---|
interface |
HighAvailabilityServices
The HighAvailabilityServices give access to all services needed for a highly-available setup.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHaServices
Abstract high availability services based on distributed system(e.g.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNonHaServices
Abstract base class for non high-availability services.
|
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedHaServices
An implementation of the
HighAvailabilityServices for the non-high-availability case
where all participants (ResourceManager, JobManagers, TaskManagers) run in the same process. |
class |
EmbeddedHaServicesWithLeadershipControl
EmbeddedHaServices extension to expose leadership granting and revoking. |
Modifier and Type | Class and Description |
---|---|
class |
StandaloneHaServices
An implementation of the
HighAvailabilityServices for the non-high-availability case. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractZooKeeperHaServices
Abstract ZooKeeper based HA services.
|
class |
ZooKeeperMultipleComponentLeaderElectionHaServices
ZooKeeper HA services that only use a single leader election per process.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobGraphStore
JobGraph instances for recovery. |
interface |
JobGraphWriter
Allows to store and remove job graphs.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobGraphStore<R extends ResourceVersion<R>>
Default implementation for
JobGraphStore . |
class |
StandaloneJobGraphStore
JobGraph instances for JobManagers running in HighAvailabilityMode.NONE . |
class |
ThrowingJobGraphWriter
JobGraphWriter implementation which does not allow to store JobGraph . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.