Modifier and Type | Class and Description |
---|---|
class |
KubernetesRunningJobsRegistry
RunningJobsRegistry implementation for Kubernetes. |
Modifier and Type | Method and Description |
---|---|
RunningJobsRegistry |
KubernetesHaServices.createRunningJobsRegistry() |
Modifier and Type | Method and Description |
---|---|
protected abstract RunningJobsRegistry |
AbstractHaServices.createRunningJobsRegistry()
Create the registry that holds information about whether jobs are currently running.
|
RunningJobsRegistry |
HighAvailabilityServices.getRunningJobsRegistry()
Gets the registry that holds information about whether jobs are currently running.
|
RunningJobsRegistry |
AbstractHaServices.getRunningJobsRegistry() |
Modifier and Type | Method and Description |
---|---|
RunningJobsRegistry |
AbstractNonHaServices.getRunningJobsRegistry() |
Modifier and Type | Class and Description |
---|---|
class |
StandaloneRunningJobsRegistry
A registry for running jobs, not-highly available.
|
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperRunningJobsRegistry
A zookeeper based registry for running jobs, highly available.
|
Modifier and Type | Method and Description |
---|---|
RunningJobsRegistry |
ZooKeeperHaServices.createRunningJobsRegistry() |
Constructor and Description |
---|
JobMasterServiceLeadershipRunner(JobMasterServiceProcessFactory jobMasterServiceProcessFactory,
LeaderElectionService leaderElectionService,
RunningJobsRegistry runningJobsRegistry,
LibraryCacheManager.ClassLoaderLease classLoaderLease,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.