Class StandaloneClientHAServices
- java.lang.Object
-
- org.apache.flink.runtime.highavailability.nonha.standalone.StandaloneClientHAServices
-
- All Implemented Interfaces:
AutoCloseable
,ClientHighAvailabilityServices
public class StandaloneClientHAServices extends Object implements ClientHighAvailabilityServices
Non-HA implementation forClientHighAvailabilityServices
. The address to web monitor is pre-configured.
-
-
Constructor Summary
Constructors Constructor Description StandaloneClientHAServices(String webMonitorAddress)
-
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
-
StandaloneClientHAServices
public StandaloneClientHAServices(String webMonitorAddress)
-
-
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
-
-