Modifier and Type | Class and Description |
---|---|
class |
SingleJobJobGraphStore
JobGraphStore implementation for a single job. |
Modifier and Type | Method and Description |
---|---|
static SessionDispatcherLeaderProcess |
SessionDispatcherLeaderProcess.create(UUID leaderSessionId,
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory dispatcherFactory,
JobGraphStore jobGraphStore,
Executor ioExecutor,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
HighAvailabilityServices.getJobGraphStore()
Gets the submitted job graph store for the job manager.
|
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
AbstractNonHaServices.getJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
ZooKeeperHaServices.getJobGraphStore() |
Modifier and Type | Class and Description |
---|---|
class |
StandaloneJobGraphStore
JobGraph instances for JobManagers running in HighAvailabilityMode.NONE . |
class |
ZooKeeperJobGraphStore
JobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
HaServicesJobGraphStoreFactory.create() |
JobGraphStore |
JobGraphStoreFactory.create()
Creates a
JobGraphStore . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.