org.apache.flink.runtime.highavailability

Interface HighAvailabilityServicesFactory

All Known Implementing Classes:

KubernetesHaServicesFactory

public interface HighAvailabilityServicesFactory

Factory interface for HighAvailabilityServices.

Method Summary

Modifier and Type	Method and Description
default ClientHighAvailabilityServices	createClientHAServices(Configuration configuration) Create a ClientHighAvailabilityServices instance.
HighAvailabilityServices	createHAServices(Configuration configuration, Executor executor) Creates a HighAvailabilityServices instance.

Method Detail

createHAServices

HighAvailabilityServices createHAServices(Configuration configuration,
                                          Executor executor)
                                   throws Exception

Creates a HighAvailabilityServices instance.

Parameters:

configuration - Flink configuration

executor - background task executor

Returns:

instance of HighAvailabilityServices

Throws:

Exception - when HAServices cannot be created

createClientHAServices

default ClientHighAvailabilityServices createClientHAServices(Configuration configuration)
                                                       throws Exception

Create a ClientHighAvailabilityServices instance.

Parameters:

configuration - Flink configuration

Returns:

instance of ClientHighAvailabilityServices

Throws:

Exception - when ClientHAServices cannot be created