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

ZKProcedureUtil.getReachedBarrierNode介绍

[英]Get the full znode path for the node used by the coordinator to trigger a global barrier execution and release on each subprocedure.
[中]获取协调器用于在每个子流程上触发全局屏障执行和释放的节点的完整znode路径。

代码示例

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

public String getReachedBarrierNode(String opInstanceName) {
 return ZKProcedureUtil.getReachedBarrierNode(this, opInstanceName);
}

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

public void clearZNodes(String procedureName) throws KeeperException {
  LOG.info("Clearing all znodes for procedure " + procedureName + "including nodes "
    + acquiredZnode + " " + reachedZnode + " " + abortZnode);

  // Make sure we trigger the watches on these nodes by creating them. (HBASE-13885)
  String acquiredBarrierNode = getAcquiredBarrierNode(procedureName);
  String reachedBarrierNode = getReachedBarrierNode(procedureName);
  String abortZNode = getAbortZNode(procedureName);

  ZKUtil.createAndFailSilent(watcher, acquiredBarrierNode);
  ZKUtil.createAndFailSilent(watcher, abortZNode);

  ZKUtil.deleteNodeRecursivelyMultiOrSequential(watcher, true, acquiredBarrierNode,
   reachedBarrierNode, abortZNode);

  if (LOG.isTraceEnabled()) {
   logZKTree(this.baseZNode);
  }
 }
}

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

@Override
public void sendGlobalBarrierReached(Procedure proc, List<String> nodeNames) throws IOException {
 String procName = proc.getName();
 String reachedNode = zkProc.getReachedBarrierNode(procName);
 LOG.debug("Creating reached barrier zk node:" + reachedNode);
 try {

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

/**
 * This acts as the ack for a completed procedure
 */
@Override
public void sendMemberCompleted(Subprocedure sub, byte[] data) throws IOException {
 String procName = sub.getName();
 LOG.debug("Marking procedure  '" + procName + "' completed for member '" + memberName
   + "' in zk");
 String joinPath =
  ZNodePaths.joinZNode(zkController.getReachedBarrierNode(procName), memberName);
 // ProtobufUtil.prependPBMagic does not take care of null
 if (data == null) {
  data = new byte[0];
 }
 try {
  ZKUtil.createAndFailSilent(zkController.getWatcher(), joinPath,
   ProtobufUtil.prependPBMagic(data));
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to post zk node:" + joinPath
    + " to join procedure barrier.", e, procName);
 }
}

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

/**
 * This attempts to create an acquired state znode for the procedure (snapshot name).
 *
 * It then looks for the reached znode to trigger in-barrier execution.  If not present we
 * have a watcher, if present then trigger the in-barrier action.
 */
@Override
public void sendMemberAcquired(Subprocedure sub) throws IOException {
 String procName = sub.getName();
 try {
  LOG.debug("Member: '" + memberName + "' joining acquired barrier for procedure (" + procName
    + ") in zk");
  String acquiredZNode = ZNodePaths.joinZNode(ZKProcedureUtil.getAcquireBarrierNode(
   zkController, procName), memberName);
  ZKUtil.createAndFailSilent(zkController.getWatcher(), acquiredZNode);
  // watch for the complete node for this snapshot
  String reachedBarrier = zkController.getReachedBarrierNode(procName);
  LOG.debug("Watch for global barrier reached:" + reachedBarrier);
  if (ZKUtil.watchAndCheckExists(zkController.getWatcher(), reachedBarrier)) {
   receivedReachedGlobalBarrier(reachedBarrier);
  }
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to acquire barrier for procedure: "
    + procName + " and member: " + memberName, e, procName);
 }
}

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

String commit = ZKProcedureUtil.getReachedBarrierNode(controller.getZkController(), operationName);
LOG.debug("Found prepared, posting commit node:" + commit);
ZKUtil.createAndFailSilent(watcher, commit);

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

/**
 * Verify that the prepare, commit and abort nodes for the operation are removed from zookeeper
 */
private void verifyZooKeeperClean(String operationName, ZKWatcher watcher,
  ZKProcedureUtil controller) throws Exception {
 String prepare = ZKProcedureUtil.getAcquireBarrierNode(controller, operationName);
 String commit = ZKProcedureUtil.getReachedBarrierNode(controller, operationName);
 String abort = ZKProcedureUtil.getAbortNode(controller, operationName);
 assertEquals("Didn't delete prepare node", -1, ZKUtil.checkExists(watcher, prepare));
 assertEquals("Didn't delete commit node", -1, ZKUtil.checkExists(watcher, commit));
 assertEquals("Didn't delete abort node", -1, ZKUtil.checkExists(watcher, abort));
}

代码示例来源：origin: harbby/presto-connectors

public String getReachedBarrierNode(String opInstanceName) {
 return ZKProcedureUtil.getReachedBarrierNode(this, opInstanceName);
}

代码示例来源：origin: co.cask.hbase/hbase

public String getReachedBarrierNode(String opInstanceName) {
 return ZKProcedureUtil.getReachedBarrierNode(this, opInstanceName);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * This acts as the ack for a completed snapshot
 */
@Override
public void sendMemberCompleted(Subprocedure sub) throws IOException {
 String procName = sub.getName();
 LOG.debug("Marking procedure  '" + procName + "' completed for member '" + memberName
   + "' in zk");
 String joinPath = ZKUtil.joinZNode(zkController.getReachedBarrierNode(procName), memberName);
 try {
  ZKUtil.createAndFailSilent(zkController.getWatcher(), joinPath);
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to post zk node:" + joinPath
    + " to join procedure barrier.", new IOException(e));
 }
}

代码示例来源：origin: co.cask.hbase/hbase

public void clearZNodes(String procedureName) throws KeeperException {
  // TODO This is potentially racy since not atomic. update when we support zk that has multi
  LOG.info("Clearing all znodes for procedure " + procedureName + "including nodes "
    + acquiredZnode + " " + reachedZnode + " " + abortZnode);
  ZKUtil.deleteNodeRecursively(watcher, getAcquiredBarrierNode(procedureName));
  ZKUtil.deleteNodeRecursively(watcher, getReachedBarrierNode(procedureName));
  ZKUtil.deleteNodeRecursively(watcher, getAbortZNode(procedureName));
 }
}

代码示例来源：origin: co.cask.hbase/hbase

@Override
public void sendGlobalBarrierReached(Procedure proc, List<String> nodeNames) throws IOException {
 String procName = proc.getName();
 String reachedNode = zkProc.getReachedBarrierNode(procName);
 LOG.debug("Creating reached barrier zk node:" + reachedNode);
 try {
  // create the reached znode and watch for the reached znodes
  ZKUtil.createWithParents(zkProc.getWatcher(), reachedNode);
  // loop through all the children of the acquire phase and watch for them
  for (String node : nodeNames) {
   String znode = ZKUtil.joinZNode(reachedNode, node);
   if (ZKUtil.watchAndCheckExists(zkProc.getWatcher(), znode)) {
    coordinator.memberFinishedBarrier(procName, node);
   }
  }
 } catch (KeeperException e) {
  throw new IOException("Failed while creating reached node:" + reachedNode, e);
 }
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * This attempts to create an acquired state znode for the procedure (snapshot name).
 *
 * It then looks for the reached znode to trigger in-barrier execution.  If not present we
 * have a watcher, if present then trigger the in-barrier action.
 */
@Override
public void sendMemberAcquired(Subprocedure sub) throws IOException {
 String procName = sub.getName();
 try {
  LOG.debug("Member: '" + memberName + "' joining acquired barrier for procedure (" + procName
    + ") in zk");
  String acquiredZNode = ZKUtil.joinZNode(ZKProcedureUtil.getAcquireBarrierNode(
   zkController, procName), memberName);
  ZKUtil.createAndFailSilent(zkController.getWatcher(), acquiredZNode);
  // watch for the complete node for this snapshot
  String reachedBarrier = zkController.getReachedBarrierNode(procName);
  LOG.debug("Watch for global barrier reached:" + reachedBarrier);
  if (ZKUtil.watchAndCheckExists(zkController.getWatcher(), reachedBarrier)) {
   receivedReachedGlobalBarrier(reachedBarrier);
  }
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to acquire barrier for procedure: "
    + procName + " and member: " + memberName, new IOException(e));
 }
}

代码示例来源：origin: harbby/presto-connectors

/**
 * This acts as the ack for a completed procedure
 */
@Override
public void sendMemberCompleted(Subprocedure sub, byte[] data) throws IOException {
 String procName = sub.getName();
 LOG.debug("Marking procedure  '" + procName + "' completed for member '" + memberName
   + "' in zk");
 String joinPath = ZKUtil.joinZNode(zkController.getReachedBarrierNode(procName), memberName);
 // ProtobufUtil.prependPBMagic does not take care of null
 if (data == null) {
  data = new byte[0];
 }
 try {
  ZKUtil.createAndFailSilent(zkController.getWatcher(), joinPath,
   ProtobufUtil.prependPBMagic(data));
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to post zk node:" + joinPath
    + " to join procedure barrier.", e, procName);
 }
}

代码示例来源：origin: harbby/presto-connectors

public void clearZNodes(String procedureName) throws KeeperException {
  LOG.info("Clearing all znodes for procedure " + procedureName + "including nodes "
    + acquiredZnode + " " + reachedZnode + " " + abortZnode);

  // Make sure we trigger the watches on these nodes by creating them. (HBASE-13885)
  String acquiredBarrierNode = getAcquiredBarrierNode(procedureName);
  String reachedBarrierNode = getReachedBarrierNode(procedureName);
  String abortZNode = getAbortZNode(procedureName);

  ZKUtil.createAndFailSilent(watcher, acquiredBarrierNode);
  ZKUtil.createAndFailSilent(watcher, abortZNode);

  ZKUtil.deleteNodeRecursivelyMultiOrSequential(watcher, true, acquiredBarrierNode,
   reachedBarrierNode, abortZNode);

  if (LOG.isTraceEnabled()) {
   logZKTree(this.baseZNode);
  }
 }
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void sendGlobalBarrierReached(Procedure proc, List<String> nodeNames) throws IOException {
 String procName = proc.getName();
 String reachedNode = zkProc.getReachedBarrierNode(procName);
 LOG.debug("Creating reached barrier zk node:" + reachedNode);
 try {

代码示例来源：origin: org.apache.hbase/hbase-server

String commit = ZKProcedureUtil.getReachedBarrierNode(controller.getZkController(), operationName);
LOG.debug("Found prepared, posting commit node:" + commit);
ZKUtil.createAndFailSilent(watcher, commit);

代码示例来源：origin: harbby/presto-connectors

/**
 * This attempts to create an acquired state znode for the procedure (snapshot name).
 *
 * It then looks for the reached znode to trigger in-barrier execution.  If not present we
 * have a watcher, if present then trigger the in-barrier action.
 */
@Override
public void sendMemberAcquired(Subprocedure sub) throws IOException {
 String procName = sub.getName();
 try {
  LOG.debug("Member: '" + memberName + "' joining acquired barrier for procedure (" + procName
    + ") in zk");
  String acquiredZNode = ZKUtil.joinZNode(ZKProcedureUtil.getAcquireBarrierNode(
   zkController, procName), memberName);
  ZKUtil.createAndFailSilent(zkController.getWatcher(), acquiredZNode);
  // watch for the complete node for this snapshot
  String reachedBarrier = zkController.getReachedBarrierNode(procName);
  LOG.debug("Watch for global barrier reached:" + reachedBarrier);
  if (ZKUtil.watchAndCheckExists(zkController.getWatcher(), reachedBarrier)) {
   receivedReachedGlobalBarrier(reachedBarrier);
  }
 } catch (KeeperException e) {
  member.controllerConnectionFailure("Failed to acquire barrier for procedure: "
    + procName + " and member: " + memberName, e, procName);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-server

/**
 * Verify that the prepare, commit and abort nodes for the operation are removed from zookeeper
 */
private void verifyZooKeeperClean(String operationName, ZKWatcher watcher,
  ZKProcedureUtil controller) throws Exception {
 String prepare = ZKProcedureUtil.getAcquireBarrierNode(controller, operationName);
 String commit = ZKProcedureUtil.getReachedBarrierNode(controller, operationName);
 String abort = ZKProcedureUtil.getAbortNode(controller, operationName);
 assertEquals("Didn't delete prepare node", -1, ZKUtil.checkExists(watcher, prepare));
 assertEquals("Didn't delete commit node", -1, ZKUtil.checkExists(watcher, commit));
 assertEquals("Didn't delete abort node", -1, ZKUtil.checkExists(watcher, abort));
}