org.apache.flink.runtime.highavailability

Interface ClientHighAvailabilityServicesFactory

All Known Implementing Classes:

DefaultClientHighAvailabilityServicesFactory

public interface ClientHighAvailabilityServicesFactory

Factory interface for ClientHighAvailabilityServices.

Method Summary

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

Method Detail

create

ClientHighAvailabilityServices create(Configuration configuration,
                                      FatalErrorHandler fatalErrorHandler)
                               throws Exception

Creates a ClientHighAvailabilityServices instance.

Parameters:

configuration - Flink configuration

fatalErrorHandler - FatalErrorHandler fatalErrorHandler to handle unexpected errors

Returns:

instance of ClientHighAvailabilityServices

Throws:

Exception - when HA services can not be created.