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 ZooKeeperCheckpointIDCounter} instance.
	 *
	 * @param client        The {@link CuratorFramework} ZooKeeper client to use
	 * @param configuration {@link Configuration} object
	 * @param jobId         ID of job to create the instance for
	 * @return {@link ZooKeeperCheckpointIDCounter} instance
	 */
Creates a  ZooKeeperCheckpointIDCounter instance.
@param client        The  CuratorFramework ZooKeeper client to use
@param configuration  Configuration object
@param jobId         ID of job to create the instance for
@return  ZooKeeperCheckpointIDCounter instance
Creates a ZooKeeperCheckpointIDCounter instance . @param client The CuratorFramework ZooKeeper client to use @param configuration Configuration object @param jobId ID of job to create the instance for @return ZooKeeperCheckpointIDCounter instance
public static ZooKeeperCheckpointIDCounter createCheckpointIDCounter(
			CuratorFramework client,
			Configuration configuration,
			JobID jobId) {
		String checkpointIdCounterPath = configuration.getString(
				HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH);
		checkpointIdCounterPath += ZooKeeperSubmittedJobGraphStore.getPathForJob(jobId);
		return new ZooKeeperCheckpointIDCounter(client, checkpointIdCounterPath);
	}
public static ZooKeeperCheckpointIDCounter createCheckpointIDCounter ( CuratorFramework client , Configuration configuration , JobID jobId ) { String checkpointIdCounterPath = configuration . getString ( HighAvailabilityOptions . HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH ) ; checkpointIdCounterPath += ZooKeeperSubmittedJobGraphStore . getPathForJob ( jobId ) ; return new ZooKeeperCheckpointIDCounter ( client , checkpointIdCounterPath ) ; }
Creates a {@link ZooKeeperCheckpointIDCounter} instance.
Creates a { @link ZooKeeperCheckpointIDCounter } instance .