Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
ApplicationDispatcherGatewayServiceFactory.create(DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Class and Description |
---|---|
class |
SingleJobJobGraphStore
JobGraphStore implementation for a single job. |
Modifier and Type | Method and Description |
---|---|
JobGraphWriter |
PartialDispatcherServicesWithJobPersistenceComponents.getJobGraphWriter() |
JobGraphWriter |
DispatcherServices.getJobGraphWriter() |
Modifier and Type | Method and Description |
---|---|
static PartialDispatcherServicesWithJobPersistenceComponents |
PartialDispatcherServicesWithJobPersistenceComponents.from(PartialDispatcherServices partialDispatcherServices,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Constructor and Description |
---|
DispatcherResourceCleanerFactory(Executor cleanupExecutor,
RetryStrategy retryStrategy,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
JobGraphWriter jobGraphWriter,
BlobServer blobServer,
HighAvailabilityServices highAvailabilityServices,
JobManagerMetricGroup jobManagerMetricGroup) |
Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId dispatcherId,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Interface and Description |
---|---|
interface |
JobGraphStore
JobGraph instances for recovery. |
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.