org.apache.flink.runtime.highavailability

Class DefaultClientHighAvailabilityServicesFactory

java.lang.Object

org.apache.flink.runtime.highavailability.DefaultClientHighAvailabilityServicesFactory

All Implemented Interfaces:

ClientHighAvailabilityServicesFactory

public class DefaultClientHighAvailabilityServicesFactory
extends Object
implements ClientHighAvailabilityServicesFactory

Default factory for creating client high availability services.

Field Summary

Fields

Modifier and Type	Field and Description
static DefaultClientHighAvailabilityServicesFactory	INSTANCE

Constructor Summary

Constructors

Constructor and Description
DefaultClientHighAvailabilityServicesFactory()

Method Summary

Modifier and Type	Method and Description
ClientHighAvailabilityServices	create(Configuration configuration, FatalErrorHandler fatalErrorHandler) Creates a ClientHighAvailabilityServices instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

public static final DefaultClientHighAvailabilityServicesFactory INSTANCE

Constructor Detail

DefaultClientHighAvailabilityServicesFactory

public DefaultClientHighAvailabilityServicesFactory()

Method Detail

create

public ClientHighAvailabilityServices create(Configuration configuration,
                                             FatalErrorHandler fatalErrorHandler)
                                      throws Exception

Description copied from interface: ClientHighAvailabilityServicesFactory

Creates a ClientHighAvailabilityServices instance.

Specified by:

create in interface ClientHighAvailabilityServicesFactory

Parameters:

configuration - Flink configuration

fatalErrorHandler - FatalErrorHandler fatalErrorHandler to handle unexpected errors

Returns:

instance of ClientHighAvailabilityServices

Throws:

Exception - when HA services can not be created.