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 ZooKeeperLeaderElectionService} 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 ZooKeeperLeaderElectionService} instance.
	 */
Creates a  ZooKeeperLeaderElectionService 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  ZooKeeperLeaderElectionService instance.
Creates a ZooKeeperLeaderElectionService 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 ZooKeeperLeaderElectionService instance .
public static ZooKeeperLeaderElectionService createLeaderElectionService(
		final CuratorFramework client,
		final Configuration configuration,
		final String pathSuffix)
	{
		final String latchPath = configuration.getString(
			HighAvailabilityOptions.HA_ZOOKEEPER_LATCH_PATH) + pathSuffix;
		final String leaderPath = configuration.getString(
			HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH) + pathSuffix;
		return new ZooKeeperLeaderElectionService(client, latchPath, leaderPath);
	}
public static ZooKeeperLeaderElectionService createLeaderElectionService ( final CuratorFramework client , final Configuration configuration , final String pathSuffix ) { final String latchPath = configuration . getString ( HighAvailabilityOptions . HA_ZOOKEEPER_LATCH_PATH ) + pathSuffix ; final String leaderPath = configuration . getString ( HighAvailabilityOptions . HA_ZOOKEEPER_LEADER_PATH ) + pathSuffix ; return new ZooKeeperLeaderElectionService ( client , latchPath , leaderPath ) ; }
Creates a {@link ZooKeeperLeaderElectionService} instance.
Creates a { @link ZooKeeperLeaderElectionService } instance .