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

ZKUtil.getNodeName介绍

[英]Get the name of the current node from the specified fully-qualified path.
[中]从指定的完全限定路径获取当前节点的名称。

代码示例

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

/**
 * Pass along the procedure global barrier notification to any listeners
 * @param path full znode path that cause the notification
 */
private void receivedReachedGlobalBarrier(String path) {
 LOG.debug("Received reached global barrier:" + path);
 String procName = ZKUtil.getNodeName(path);
 this.member.receivedReachedGlobalBarrier(procName);
}

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

@Override
public void nodeDeleted(String path) {
 if (keysParentZNode.equals(ZKUtil.getParent(path))) {
  String keyId = ZKUtil.getNodeName(path);
  try {
   Integer id = Integer.valueOf(keyId);
   secretManager.removeKey(id);
  } catch (NumberFormatException nfe) {
   LOG.error("Invalid znode name for key ID '"+keyId+"'", nfe);
  }
 }
}

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

@Override
 public void run() {
  // update cache on an existing table node
  String entry = ZKUtil.getNodeName(path);
  try {
   byte[] data = ZKUtil.getDataAndWatch(watcher, path);
   refreshAuthManager(entry, data);
  } catch (KeeperException ke) {
   LOG.error("Error reading data from zookeeper for node " + entry, ke);
   // only option is to abort
   watcher.abort("ZooKeeper error getting data for node " + entry, ke);
  } catch (IOException ioe) {
   LOG.error("Error reading permissions writables", ioe);
  }
 }
});

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

@Override
public void nodeDeleted(final String path) {
 if(path.startsWith(watcher.getZNodePaths().drainingZNode)) {
  final ServerName sn = ServerName.valueOf(ZKUtil.getNodeName(path));
  LOG.info("Draining RS node deleted, removing from list [" +
    sn + "]");
  remove(sn);
 }
}

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

@Override
 public void run() {
  String table = ZKUtil.getNodeName(path);
  if(AccessControlLists.isNamespaceEntry(table)) {
   authManager.removeNamespace(Bytes.toBytes(table));
  } else {
   authManager.removeTable(TableName.valueOf(table));
  }
 }
});

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

private void add(final List<String> servers) throws IOException {
 synchronized(this.drainingServers) {
  this.drainingServers.clear();
  for (String n: servers) {
   final ServerName sn = ServerName.valueOf(ZKUtil.getNodeName(n));
   this.drainingServers.add(sn);
   this.serverManager.addServerToDrainList(sn);
   LOG.info("Draining RS node created, adding to list [" +
     sn + "]");
  }
 }
}

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

@Override
public void nodeDeleted(String path) {
 if (!path.startsWith(archiveHFileZNode)) return;
 LOG.debug("Archive node: " + path + " deleted");
 String table = path.substring(archiveHFileZNode.length());
 // if we stop archiving all tables
 if (table.length() == 0) {
  // make sure we have the tracker before deleting the archive
  // but if we don't, we don't care about delete
  clearTables();
  // watches are one-time events, so we need to renew our subscription to
  // the archive node and might as well check to make sure archiving
  // didn't come back on at the same time
  checkEnabledAndUpdate();
  return;
 }
 // just stop archiving one table
 // note that we don't attempt to add another watch for that table into zk.
 // We have no assurances that the table will be archived again (or even
 // exists for that matter), so its better not to add unnecessary load to
 // zk for watches. If the table is created again, then we will get the
 // notification in childrenChanaged.
 getMonitor().removeTable(ZKUtil.getNodeName(path));
}

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

private void refreshNodes(List<ZKUtil.NodeAndData> nodes) {
 for (ZKUtil.NodeAndData n : nodes) {
  if (Thread.interrupted()) {
   // Use Thread.interrupted so that we clear interrupt status
   break;
  }
  if (n.isEmpty()) continue;
  String path = n.getNode();
  String entry = (ZKUtil.getNodeName(path));
  try {
   refreshAuthManager(entry, n.getData());
  } catch (IOException ioe) {
   LOG.error("Failed parsing permissions for table '" + entry +
     "' from zk", ioe);
  }
 }
}

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

/**
 * Stop tracking a table. Ensures that the table doesn't exist, but if it does, it attempts to add
 * the table back via {@link #addAndReWatchTable(String)} - its a 'safe' removal.
 * @param tableZnode full zookeeper path to the table to be added
 * @throws KeeperException if an unexpected zk exception occurs
 */
private void safeStopTrackingTable(String tableZnode) throws KeeperException {
 getMonitor().removeTable(ZKUtil.getNodeName(tableZnode));
 // if the table exists, then add and rewatch it
 if (ZKUtil.checkExists(watcher, tableZnode) >= 0) {
  addAndReWatchTable(tableZnode);
 }
}

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

/**
 * Add this table to the tracker and then read a watch on that node.
 * <p>
 * Handles situation where table is deleted in the time between the update and resetting the watch
 * by deleting the table via {@link #safeStopTrackingTable(String)}
 * @param tableZnode full zookeeper path to the table to be added
 * @throws KeeperException if an unexpected zk exception occurs
 */
private void addAndReWatchTable(String tableZnode) throws KeeperException {
 getMonitor().addTable(ZKUtil.getNodeName(tableZnode));
 // re-add a watch to the table created
 // and check to make sure it wasn't deleted
 if (!ZKUtil.watchAndCheckExists(watcher, tableZnode)) {
  safeStopTrackingTable(tableZnode);
 }
}

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

private void refreshNodes(List<ZKUtil.NodeAndData> nodes) {
 for (ZKUtil.NodeAndData n : nodes) {
  String path = n.getNode();
  String keyId = ZKUtil.getNodeName(path);
  try {
   byte[] data = n.getData();
   if (data == null || data.length == 0) {
    LOG.debug("Ignoring empty node "+path);
    continue;
   }
   AuthenticationKey key = (AuthenticationKey)Writables.getWritable(
     data, new AuthenticationKey());
   secretManager.addKey(key);
  } catch (IOException ioe) {
   LOG.error(HBaseMarkers.FATAL, "Failed reading new secret key for id '" +
     keyId + "' from zk", ioe);
   watcher.abort("Error deserializing key from znode "+path, ioe);
  }
 }
}

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

String opName = ZKUtil.getNodeName(abortZNode);
try {
 byte[] data = ZKUtil.getData(zkController.getWatcher(), abortZNode);

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

String procName = ZKUtil.getNodeName(abortNode);
ForeignException ee = null;
try {

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

if (isAcquiredPathNode(path)) {
 coordinator.memberAcquiredBarrier(ZKUtil.getNodeName(ZKUtil.getParent(path)),
  ZKUtil.getNodeName(path));
} else if (isReachedPathNode(path)) {
 String procName = ZKUtil.getNodeName(ZKUtil.getParent(path));
 String member = ZKUtil.getNodeName(path);

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

String opName = ZKUtil.getNodeName(path);

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

@Override
public void nodeDeleted(String path) {
 if (nsZNode.equals(ZKUtil.getParent(path))) {
  String nsName = ZKUtil.getNodeName(path);
  cache.remove(nsName);
 }
}

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

@Override
public void nodeDeleted(final String path) {
 if(path.startsWith(watcher.drainingZNode)) {
  final ServerName sn = new ServerName(ZKUtil.getNodeName(path));
  LOG.info("Draining RS node deleted, removing from list [" +
    sn + "]");
  remove(sn);
 }
}

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

private void add(final List<String> servers) throws IOException {
 synchronized(this.regionServers) {
  this.regionServers.clear();
  for (String n: servers) {
   ServerName sn = ServerName.parseServerName(ZKUtil.getNodeName(n));
   this.regionServers.add(sn);
  }
 }
}

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

/**
 * Pass along the procedure global barrier notification to any listeners
 * @param path full znode path that cause the notification
 */
private void receivedReachedGlobalBarrier(String path) {
 LOG.debug("Recieved reached global barrier:" + path);
 String procName = ZKUtil.getNodeName(path);
 this.member.receivedReachedGlobalBarrier(procName);
}

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

@Override
public void nodeDeleted(final String path) {
 if(path.startsWith(watcher.drainingZNode)) {
  final ServerName sn = ServerName.valueOf(ZKUtil.getNodeName(path));
  LOG.info("Draining RS node deleted, removing from list [" +
    sn + "]");
  remove(sn);
 }
}