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

ZKProcedureUtil.getAcquiredBarrierNode介绍

暂无

代码示例

代码示例来源：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

String acquire = zkProc.getAcquiredBarrierNode(procName);
LOG.debug("Creating acquire znode:" + acquire);
try {

代码示例来源：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

String acquire = zkProc.getAcquiredBarrierNode(procName);
LOG.debug("Creating acquire znode:" + acquire);
try {

代码示例来源：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

String acquire = zkProc.getAcquiredBarrierNode(procName);
LOG.debug("Creating acquire znode:" + acquire);
try {