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

ZKPermissionWatcher.refreshAuthManager介绍

暂无

代码示例

代码示例来源：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: harbby/presto-connectors

private void refreshNodes(List<ZKUtil.NodeAndData> nodes) {
 for (ZKUtil.NodeAndData n : nodes) {
  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: harbby/presto-connectors

@Override
public void nodeDataChanged(String path) {
 waitUntilStarted();
 if (aclZNode.equals(ZKUtil.getParent(path))) {
  // 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);
  }
 }
}