Class ZooKeeperClientHAServices
- java.lang.Object
-
- org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperClientHAServices
-
- All Implemented Interfaces:
AutoCloseable
,ClientHighAvailabilityServices
public class ZooKeeperClientHAServices extends Object implements ClientHighAvailabilityServices
ZooKeeper based implementation forClientHighAvailabilityServices
.
-
-
Constructor Summary
Constructors Constructor Description ZooKeeperClientHAServices(CuratorFrameworkWithUnhandledErrorListener curatorFrameworkWrapper, Configuration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
LeaderRetrievalService
getClusterRestEndpointLeaderRetriever()
Get the leader retriever for the cluster's rest endpoint.
-
-
-
Constructor Detail
-
ZooKeeperClientHAServices
public ZooKeeperClientHAServices(@Nonnull CuratorFrameworkWithUnhandledErrorListener curatorFrameworkWrapper, @Nonnull Configuration configuration)
-
-
Method Detail
-
getClusterRestEndpointLeaderRetriever
public LeaderRetrievalService getClusterRestEndpointLeaderRetriever()
Description copied from interface:ClientHighAvailabilityServices
Get the leader retriever for the cluster's rest endpoint.- Specified by:
getClusterRestEndpointLeaderRetriever
in interfaceClientHighAvailabilityServices
- Returns:
- the leader retriever for cluster's rest endpoint.
-
close
public void close() throws Exception
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-
-