public class KubernetesMultipleComponentLeaderElectionHaServicesFactory extends Object implements HighAvailabilityServicesFactory
KubernetesMultipleComponentLeaderElectionHaServices
.Constructor and Description |
---|
KubernetesMultipleComponentLeaderElectionHaServicesFactory() |
Modifier and Type | Method and Description |
---|---|
HighAvailabilityServices |
createHAServices(Configuration configuration,
Executor executor)
Creates a
HighAvailabilityServices instance. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createClientHAServices
public KubernetesMultipleComponentLeaderElectionHaServicesFactory()
public HighAvailabilityServices createHAServices(Configuration configuration, Executor executor) throws Exception
HighAvailabilityServicesFactory
HighAvailabilityServices
instance.createHAServices
in interface HighAvailabilityServicesFactory
configuration
- Flink configurationexecutor
- background task executorHighAvailabilityServices
Exception
- when HAServices cannot be createdCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.