Modifier and Type | Class and Description |
---|---|
class |
SingleJobSubmittedJobGraphStore
SubmittedJobGraphStore implementation for a single job. |
Constructor and Description |
---|
Dispatcher(RpcService rpcService,
String endpointId,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
SubmittedJobGraphStore submittedJobGraphStore,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroup jobManagerMetricGroup,
String metricServiceQueryAddress,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
JobManagerRunnerFactory jobManagerRunnerFactory,
FatalErrorHandler fatalErrorHandler,
HistoryServerArchivist historyServerArchivist) |
Modifier and Type | Method and Description |
---|---|
SubmittedJobGraphStore |
HighAvailabilityServices.getSubmittedJobGraphStore()
Gets the submitted job graph store for the job manager
|
Modifier and Type | Method and Description |
---|---|
SubmittedJobGraphStore |
AbstractNonHaServices.getSubmittedJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
SubmittedJobGraphStore |
ZooKeeperHaServices.getSubmittedJobGraphStore() |
Modifier and Type | Class and Description |
---|---|
class |
StandaloneSubmittedJobGraphStore
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.NONE . |
class |
ZooKeeperSubmittedJobGraphStore
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Modifier and Type | Method and Description |
---|---|
SubmittedJobGraphStore |
AbstractYarnNonHaServices.getSubmittedJobGraphStore() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.