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

ZooKeeperNodeTracker.nodeDataChanged介绍

暂无

代码示例

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

@Override
 public synchronized void nodeDataChanged(String path) {
  if (path.equals(node)) {
   super.nodeDataChanged(path);
   readPeerStateZnode();
  }
 }
}

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

@Override
 public synchronized void nodeDataChanged(String path) {
  if (path.equals(node)) {
   super.nodeDataChanged(path);
   readReplicationStateZnode();
  }
 }
}

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

@Override
 public synchronized void nodeDataChanged(String path) {
  if (path.equals(node)) {
   super.nodeDataChanged(path);
  }
 }
}

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

@Override
 public synchronized void nodeDataChanged(String path) {
  if (path.equals(node)) {
   super.nodeDataChanged(path);
   try {
    readPeerStateZnode();
   } catch (DeserializationException e) {
    LOG.warn("Failed deserializing the content of " + path, e);
   }
  }
 }
}

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

/**
 * Set the balancer on/off
 * @param balancerOn
 * @throws KeeperException
 */
public void setBalancerOn(boolean balancerOn) throws KeeperException {
byte [] upData = toByteArray(balancerOn);
 try {
  ZKUtil.setData(watcher, watcher.balancerZNode, upData);
 } catch(KeeperException.NoNodeException nne) {
  ZKUtil.createAndWatch(watcher, watcher.balancerZNode, upData);
 }
 super.nodeDataChanged(watcher.balancerZNode);
}

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

/**
 * Set region normalizer on/off
 * @param normalizerOn whether normalizer should be on or off
 * @throws KeeperException
 */
public void setNormalizerOn(boolean normalizerOn) throws KeeperException {
 byte [] upData = toByteArray(normalizerOn);
 try {
  ZKUtil.setData(watcher, watcher.getRegionNormalizerZNode(), upData);
 } catch(KeeperException.NoNodeException nne) {
  ZKUtil.createAndWatch(watcher, watcher.getRegionNormalizerZNode(), upData);
 }
 super.nodeDataChanged(watcher.getRegionNormalizerZNode());
}