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

ZKProcedureUtil.getAbortNode介绍

[英]Get the full znode path for the node used by the coordinator or member to trigger an abort of the global barrier acquisition or execution in subprocedures.
[中]获取协调器或成员用于触发子流程中全局屏障获取或执行中止的节点的完整znode路径。

代码示例

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

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

代码示例来源：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: co.cask.hbase/hbase

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

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

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

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