本文整理了Java中org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore.getLockPath()方法的一些代码示例，展示了ZooKeeperStateHandleStore.getLockPath()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperStateHandleStore.getLockPath()方法的具体详情如下：
包路径：org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore
类名称：ZooKeeperStateHandleStore
方法名：getLockPath

ZooKeeperStateHandleStore.getLockPath介绍

[英]Returns the path for the lock node relative to the given path.
[中]返回锁节点相对于给定路径的路径。

代码示例

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

/**
 * Releases the lock from the node under the given ZooKeeper path. If no lock exists, then nothing happens.
 *
 * @param pathInZooKeeper Path describing the ZooKeeper node
 * @throws Exception if the delete operation of the lock node fails
 */
public void release(String pathInZooKeeper) throws Exception {
  final String path = normalizePath(pathInZooKeeper);
  try {
    client.delete().forPath(getLockPath(path));
  } catch (KeeperException.NoNodeException ignored) {
    // we have never locked this node
  } catch (Exception e) {
    throw new Exception("Could not release the lock: " + getLockPath(pathInZooKeeper) + '.', e);
  }
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

/**
 * Releases the lock from the node under the given ZooKeeper path. If no lock exists, then nothing happens.
 *
 * @param pathInZooKeeper Path describing the ZooKeeper node
 * @throws Exception if the delete operation of the lock node fails
 */
public void release(String pathInZooKeeper) throws Exception {
  final String path = normalizePath(pathInZooKeeper);
  try {
    client.delete().forPath(getLockPath(path));
  } catch (KeeperException.NoNodeException ignored) {
    // we have never locked this node
  } catch (Exception e) {
    throw new Exception("Could not release the lock: " + getLockPath(pathInZooKeeper) + '.', e);
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime

/**
 * Releases the lock from the node under the given ZooKeeper path. If no lock exists, then nothing happens.
 *
 * @param pathInZooKeeper Path describing the ZooKeeper node
 * @throws Exception if the delete operation of the lock node fails
 */
public void release(String pathInZooKeeper) throws Exception {
  final String path = normalizePath(pathInZooKeeper);
  try {
    client.delete().forPath(getLockPath(path));
  } catch (KeeperException.NoNodeException ignored) {
    // we have never locked this node
  } catch (Exception e) {
    throw new Exception("Could not release the lock: " + getLockPath(pathInZooKeeper) + '.', e);
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

/**
 * Releases the lock from the node under the given ZooKeeper path. If no lock exists, then nothing happens.
 *
 * @param pathInZooKeeper Path describing the ZooKeeper node
 * @throws Exception if the delete operation of the lock node fails
 */
public void release(String pathInZooKeeper) throws Exception {
  final String path = normalizePath(pathInZooKeeper);
  try {
    client.delete().forPath(getLockPath(path));
  } catch (KeeperException.NoNodeException ignored) {
    // we have never locked this node
  } catch (Exception e) {
    throw new Exception("Could not release the lock: " + getLockPath(pathInZooKeeper) + '.', e);
  }
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

client.create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path));
} catch (KeeperException.NodeExistsException ignored) {

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

client.create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path));
} catch (KeeperException.NodeExistsException ignored) {

代码示例来源：origin: org.apache.flink/flink-runtime

client.create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path));
} catch (KeeperException.NodeExistsException ignored) {

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

client.create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path));
} catch (KeeperException.NodeExistsException ignored) {

代码示例来源：origin: com.alibaba.blink/flink-runtime

.and().create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path))
.and().commit();

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

.and().create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path))
.and().commit();

代码示例来源：origin: org.apache.flink/flink-runtime

.and().create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path))
.and().commit();

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

.and().create().withMode(CreateMode.EPHEMERAL).forPath(getLockPath(path))
.and().commit();