Class KubernetesHaServicesFactory
- java.lang.Object
-
- org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory
-
- All Implemented Interfaces:
HighAvailabilityServicesFactory
public class KubernetesHaServicesFactory extends Object implements HighAvailabilityServicesFactory
Factory for creating Kubernetes high availability services.
-
-
Constructor Summary
Constructors Constructor Description KubernetesHaServicesFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description HighAvailabilityServices
createHAServices(Configuration configuration, Executor executor)
Creates aHighAvailabilityServices
instance.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.runtime.highavailability.HighAvailabilityServicesFactory
createClientHAServices
-
-
-
-
Method Detail
-
createHAServices
public HighAvailabilityServices createHAServices(Configuration configuration, Executor executor) throws Exception
Description copied from interface:HighAvailabilityServicesFactory
Creates aHighAvailabilityServices
instance.- Specified by:
createHAServices
in interfaceHighAvailabilityServicesFactory
- Parameters:
configuration
- Flink configurationexecutor
- background task executor- Returns:
- instance of
HighAvailabilityServices
- Throws:
Exception
- when HAServices cannot be created
-
-