flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
/**
	 * Creates a {@link ZooKeeperLeaderRetrievalService} instance.
	 *
	 * @param client        The {@link CuratorFramework} ZooKeeper client to use
	 * @param configuration {@link Configuration} object containing the configuration values
	 * @param pathSuffix    The path suffix which we want to append
	 * @return {@link ZooKeeperLeaderRetrievalService} instance.
	 * @throws Exception
	 */
Creates a  ZooKeeperLeaderRetrievalService instance.
@param client        The  CuratorFramework ZooKeeper client to use
@param configuration  Configuration object containing the configuration values
@param pathSuffix    The path suffix which we want to append
@return  ZooKeeperLeaderRetrievalService instance.
@throws Exception
Creates a ZooKeeperLeaderRetrievalService instance . @param client The CuratorFramework ZooKeeper client to use @param configuration Configuration object containing the configuration values @param pathSuffix The path suffix which we want to append @return ZooKeeperLeaderRetrievalService instance . @throws Exception
public static ZooKeeperLeaderRetrievalService createLeaderRetrievalService(
		final CuratorFramework client,
		final Configuration configuration,
		final String pathSuffix)
	{
		String leaderPath = configuration.getString(
			HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH) + pathSuffix;
		return new ZooKeeperLeaderRetrievalService(client, leaderPath);
	}
public static ZooKeeperLeaderRetrievalService createLeaderRetrievalService ( final CuratorFramework client , final Configuration configuration , final String pathSuffix ) { String leaderPath = configuration . getString ( HighAvailabilityOptions . HA_ZOOKEEPER_LEADER_PATH ) + pathSuffix ; return new ZooKeeperLeaderRetrievalService ( client , leaderPath ) ; }
Creates a {@link ZooKeeperLeaderRetrievalService} instance.
Creates a { @link ZooKeeperLeaderRetrievalService } instance .