Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
ApplicationDispatcherGatewayServiceFactory.create(DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
JobGraphWriter jobGraphWriter) |
Modifier and Type | Class and Description |
---|---|
class |
SingleJobJobGraphStore
JobGraphStore implementation for a single job. |
Modifier and Type | Method and Description |
---|---|
JobGraphWriter |
PartialDispatcherServicesWithJobGraphStore.getJobGraphWriter() |
JobGraphWriter |
DispatcherServices.getJobGraphWriter() |
Modifier and Type | Method and Description |
---|---|
static PartialDispatcherServicesWithJobGraphStore |
PartialDispatcherServicesWithJobGraphStore.from(PartialDispatcherServices partialDispatcherServices,
JobGraphWriter jobGraphWriter) |
Constructor and Description |
---|
DispatcherServices(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
ExecutionGraphInfoStore executionGraphInfoStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
JobManagerMetricGroup jobManagerMetricGroup,
JobGraphWriter jobGraphWriter,
JobManagerRunnerFactory jobManagerRunnerFactory,
Executor ioExecutor) |
PartialDispatcherServicesWithJobGraphStore(Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroupFactory jobManagerMetricGroupFactory,
ExecutionGraphInfoStore executionGraphInfoStore,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist,
String metricQueryServiceAddress,
Executor ioExecutor,
JobGraphWriter jobGraphWriter) |
Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
JobGraphWriter jobGraphWriter) |
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–2023 The Apache Software Foundation. All rights reserved.