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 | Method and Description |
---|---|
JobResultStore |
PartialDispatcherServicesWithJobPersistenceComponents.getJobResultStore() |
JobResultStore |
DispatcherServices.getJobResultStore() |
Modifier and Type | Method and Description |
---|---|
static PartialDispatcherServicesWithJobPersistenceComponents |
PartialDispatcherServicesWithJobPersistenceComponents.from(PartialDispatcherServices partialDispatcherServices,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId dispatcherId,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
static SessionDispatcherLeaderProcess |
SessionDispatcherLeaderProcess.create(UUID leaderSessionId,
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory dispatcherFactory,
JobGraphStore jobGraphStore,
JobResultStore jobResultStore,
Executor ioExecutor,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractThreadsafeJobResultStore
An abstract class for threadsafe implementations of the
JobResultStore . |
class |
FileSystemJobResultStore
An implementation of the
JobResultStore which persists job result data to an underlying
distributed filesystem. |
Modifier and Type | Method and Description |
---|---|
JobResultStore |
AbstractHaServices.getJobResultStore() |
JobResultStore |
HighAvailabilityServices.getJobResultStore()
Gets the store that holds information about the state of finished jobs.
|
Constructor and Description |
---|
AbstractHaServices(Configuration config,
Executor ioExecutor,
BlobStoreService blobStoreService,
JobResultStore jobResultStore) |
Modifier and Type | Method and Description |
---|---|
JobResultStore |
AbstractNonHaServices.getJobResultStore() |
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedJobResultStore
A thread-safe in-memory implementation of the
JobResultStore . |
Modifier and Type | Method and Description |
---|---|
JobResultStore |
JobPersistenceComponentFactory.createJobResultStore()
Creates
JobResultStore instances. |
JobResultStore |
HaServicesJobPersistenceComponentFactory.createJobResultStore() |
Constructor and Description |
---|
JobMasterServiceLeadershipRunner(JobMasterServiceProcessFactory jobMasterServiceProcessFactory,
LeaderElectionService leaderElectionService,
JobResultStore jobResultStore,
LibraryCacheManager.ClassLoaderLease classLoaderLease,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.