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

ZooKeeperStateHandleStore.getAllAndLock介绍

[英]Gets all available state handles from ZooKeeper and locks the respective state nodes.

If there is a concurrent modification, the operation is retried until it succeeds.
[中]从ZooKeeper获取所有可用的状态句柄，并锁定相应的状态节点。
如果存在并发修改，则会重试该操作，直到成功。

代码示例

代码示例来源：origin: apache/flink

@Override
public List<MesosWorkerStore.Worker> recoverWorkers() throws Exception {
  synchronized (startStopLock) {
    verifyIsRunning();
    List<Tuple2<RetrievableStateHandle<Worker>, String>> handles = workersInZooKeeper.getAllAndLock();
    if (handles.isEmpty()) {
      return Collections.emptyList();
    }
    else {
      List<MesosWorkerStore.Worker> workers = new ArrayList<>(handles.size());
      for (Tuple2<RetrievableStateHandle<Worker>, String> handle : handles) {
        final Worker worker;
        try {
          worker = handle.f0.retrieveState();
        } catch (ClassNotFoundException cnfe) {
          throw new FlinkException("Could not retrieve Mesos worker from state handle under " +
            handle.f1 + ". This indicates that you are trying to recover from state written by an " +
            "older Flink version which is not compatible. Try cleaning the state handle store.", cnfe);
        } catch (IOException ioe) {
          throw new FlinkException("Could not retrieve Mesos worker from state handle under " +
            handle.f1 + ". This indicates that the retrieved state handle is broken. Try cleaning " +
            "the state handle store.", ioe);
        }
        workers.add(worker);
      }
      return workers;
    }
  }
}

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

while (true) {
  try {
    initialCheckpoints = checkpointsInZooKeeper.getAllAndLock();
    break;

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

while (true) {
  try {
    initialCheckpoints = checkpointsInZooKeeper.getAllAndLock();
    break;