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

ZKVisibilityLabelWatcher介绍

[英]A zk watcher that watches the labels table znode. This would create a znode /hbase/visibility_labels and will have a serialized form of a set of labels in the system.
[中]监视标签表znode的zk观察器。这将创建znode/hbase/visibility_标签，并在系统中具有一组标签的序列化形式。

代码示例

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

private VisibilityLabelsCache(ZKWatcher watcher, Configuration conf) throws IOException {
 zkVisibilityWatcher = new ZKVisibilityLabelWatcher(watcher, this, conf);
 try {
  zkVisibilityWatcher.start();
 } catch (KeeperException ke) {
  LOG.error("ZooKeeper initialization failed", ke);
  throw new IOException(ke);
 }
}

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

/**
 * Creates the singleton instance, if not yet present, and returns the same.
 * @param watcher
 * @param conf
 * @return Singleton instance of VisibilityLabelsCache
 * @throws IOException
 */
public synchronized static VisibilityLabelsCache createAndGet(ZKWatcher watcher,
  Configuration conf) throws IOException {
 // VisibilityLabelService#init() for different regions (in same RS) passes same instance of
 // watcher as all get the instance from RS.
 // watcher != instance.zkVisibilityWatcher.getWatcher() - This check is needed only in UTs with
 // RS restart. It will be same JVM in which RS restarts and instance will be not null. But the
 // watcher associated with existing instance will be stale as the restarted RS will have new
 // watcher with it.
 if (instance == null || watcher != instance.zkVisibilityWatcher.getWatcher()) {
  instance = new VisibilityLabelsCache(watcher, conf);
 }
 return instance;
}

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

@Override
public void nodeDataChanged(String path) {
 if (path.equals(labelZnode) || path.equals(userAuthsZnode)) {
  try {
   watcher.sync(path);
   byte[] data = ZKUtil.getDataAndWatch(watcher, path);
   if (path.equals(labelZnode)) {
    refreshVisibilityLabelsCache(data);
   } else {
    refreshUserAuthsCache(data);
   }
  } catch (KeeperException ke) {
   LOG.error("Error reading data from zookeeper for node " + path, ke);
   // only option is to abort
   watcher.abort("ZooKeeper error getting data for node " + path, ke);
  }
 }
}

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

public void writeToZookeeper(byte[] data, boolean labelsOrUserAuths) throws IOException {
  // Update local state, then send it to zookeeper
  if (labelsOrUserAuths) {
   // True for labels
   this.refreshLabelsCache(data);
  } else {
   // False for user auths
   this.refreshUserAuthsCache(data);
  }
  this.zkVisibilityWatcher.writeToZookeeper(data, labelsOrUserAuths);
 }
}

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

public void writeToZookeeper(byte[] data, boolean labelsOrUserAuths) throws IOException {
  // Update local state, then send it to zookeeper
  if (labelsOrUserAuths) {
   // True for labels
   this.refreshLabelsCache(data);
  } else {
   // False for user auths
   this.refreshUserAuthsCache(data);
  }
  this.zkVisibilityWatcher.writeToZookeeper(data, labelsOrUserAuths);
 }
}

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

public void start() throws KeeperException {
 watcher.registerListener(this);
 ZKUtil.createWithParents(watcher, labelZnode);
 ZKUtil.createWithParents(watcher, userAuthsZnode);
 byte[] data = ZKUtil.getDataAndWatch(watcher, labelZnode);
 if (data != null && data.length > 0) {
  refreshVisibilityLabelsCache(data);
 }
 data = ZKUtil.getDataAndWatch(watcher, userAuthsZnode);
 if (data != null && data.length > 0) {
  refreshUserAuthsCache(data);
 }
}

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

private VisibilityLabelsCache(ZooKeeperWatcher watcher, Configuration conf) throws IOException {
 zkVisibilityWatcher = new ZKVisibilityLabelWatcher(watcher, this, conf);
 try {
  zkVisibilityWatcher.start();
 } catch (KeeperException ke) {
  LOG.error("ZooKeeper initialization failed", ke);
  throw new IOException(ke);
 }
}

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

/**
 * Creates the singleton instance, if not yet present, and returns the same.
 * @param watcher
 * @param conf
 * @return Singleton instance of VisibilityLabelsCache
 * @throws IOException
 */
public synchronized static VisibilityLabelsCache createAndGet(ZooKeeperWatcher watcher,
  Configuration conf) throws IOException {
 // VisibilityLabelService#init() for different regions (in same RS) passes same instance of
 // watcher as all get the instance from RS.
 // watcher != instance.zkVisibilityWatcher.getWatcher() - This check is needed only in UTs with
 // RS restart. It will be same JVM in which RS restarts and instance will be not null. But the
 // watcher associated with existing instance will be stale as the restarted RS will have new
 // watcher with it.
 if (instance == null || watcher != instance.zkVisibilityWatcher.getWatcher()) {
  instance = new VisibilityLabelsCache(watcher, conf);
 }
 return instance;
}

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

@Override
public void nodeDataChanged(String path) {
 if (path.equals(labelZnode) || path.equals(userAuthsZnode)) {
  try {
   watcher.sync(path);
   byte[] data = ZKUtil.getDataAndWatch(watcher, path);
   if (path.equals(labelZnode)) {
    refreshVisibilityLabelsCache(data);
   } else {
    refreshUserAuthsCache(data);
   }
  } catch (KeeperException ke) {
   LOG.error("Error reading data from zookeeper for node " + path, ke);
   // only option is to abort
   watcher.abort("Zookeeper error getting data for node " + path, ke);
  }
 }
}

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

public void start() throws KeeperException {
 watcher.registerListener(this);
 ZKUtil.createWithParents(watcher, labelZnode);
 ZKUtil.createWithParents(watcher, userAuthsZnode);
 byte[] data = ZKUtil.getDataAndWatch(watcher, labelZnode);
 if (data != null && data.length > 0) {
  refreshVisibilityLabelsCache(data);
 }
 data = ZKUtil.getDataAndWatch(watcher, userAuthsZnode);
 if (data != null && data.length > 0) {
  refreshUserAuthsCache(data);
 }
}