Modifier and Type | Method and Description |
---|---|
JobGraphStore |
KubernetesHaServices.createJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
static JobGraphStore |
KubernetesUtils.createJobGraphStore(Configuration configuration,
FlinkKubeClient flinkKubeClient,
String configMapName,
String lockIdentity)
Create a
DefaultJobGraphStore with NoOpJobGraphStoreWatcher . |
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 |
---|---|
protected abstract JobGraphStore |
AbstractHaServices.createJobGraphStore()
Create the submitted job graph store for the job manager.
|
JobGraphStore |
HighAvailabilityServices.getJobGraphStore()
Gets the submitted job graph store for the job manager.
|
JobGraphStore |
AbstractHaServices.getJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
AbstractNonHaServices.getJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
ZooKeeperHaServices.createJobGraphStore() |
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 . |
Modifier and Type | Method and Description |
---|---|
JobGraphStore |
JobGraphStoreFactory.create()
Creates a
JobGraphStore . |
JobGraphStore |
HaServicesJobGraphStoreFactory.create() |
Modifier and Type | Method and Description |
---|---|
static JobGraphStore |
ZooKeeperUtils.createJobGraphs(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client,
Configuration configuration)
Creates a
DefaultJobGraphStore instance with ZooKeeperStateHandleStore ,
ZooKeeperJobGraphStoreWatcher and ZooKeeperJobGraphStoreUtil . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.