Modifier and Type | Class and Description |
---|---|
class |
BlobServer
This class implements the BLOB server.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobManagerRunnerRegistry
JobManagerRunner collects running jobs represented by JobManagerRunner . |
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. |
class |
SingleJobJobGraphStore
JobGraphStore implementation for a single job. |
Modifier and Type | Method and Description |
---|---|
static DefaultResourceCleaner.Builder<LocallyCleanableResource> |
DefaultResourceCleaner.forLocallyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor,
Executor cleanupExecutor,
RetryStrategy retryStrategy) |
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 . |
Modifier and Type | Class and Description |
---|---|
class |
JobManagerMetricGroup
Special
MetricGroup representing a JobManager. |
static class |
UnregisteredMetricGroups.UnregisteredJobManagerMetricGroup
A safe drop-in replacement for
JobManagerMetricGroup s. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.