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

ZooKeeperNodeTracker介绍

[英]Tracks the availability and value of a single ZooKeeper node.

Utilizes the ZooKeeperListener interface to get the necessary ZooKeeper events related to the node.

This is the base class used by trackers in both the Master and RegionServers.
[中]跟踪单个ZooKeeper节点的可用性和价值。
利用ZooKeeperListener接口获取与节点相关的必要ZooKeeper事件。
这是主服务器和区域服务器中跟踪器使用的基类。

代码示例

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

/**
 * Gets the data of the node, blocking until the node is available.
 *
 * @return data of the node
 * @throws InterruptedException if the waiting thread is interrupted
 */
public synchronized byte [] blockUntilAvailable()
throws InterruptedException {
 return blockUntilAvailable(0, false);
}

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

/**
 * Checks if cluster is up.
 * @return true if root region location is available, false if not
 */
public boolean isClusterUp() {
 return super.getData(false) != null;
}

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

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

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

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

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

@Override
 public void nodeDeleted(String path) {
  super.nodeDeleted(path);
 }
}

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

/**
 * Starts the tracking of the node in ZooKeeper.
 *
 * <p>Use {@link #blockUntilAvailable()} to block until the node is available
 * or {@link #getData(boolean)} to get the data of the node if it is available.
 */
public synchronized void start() {
 this.watcher.registerListener(this);
 try {
  if(ZKUtil.watchAndCheckExists(watcher, node)) {
   byte [] data = ZKUtil.getDataAndWatch(watcher, node);
   if(data != null) {
    this.data = data;
   } else {
    // It existed but now does not, try again to ensure a watch is set
    LOG.debug("Try starting again because there is no data from " + node);
    start();
   }
  }
 } catch (KeeperException e) {
  abortable.abort("Unexpected exception during initialization, aborting", e);
 }
}

代码示例来源：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 nodeCreated(String path) {
 if (!path.equals(node)) return;
 try {
  byte [] data = ZKUtil.getDataAndWatch(watcher, node);
  if (data != null) {
   this.data = data;
   notifyAll();
  } else {
   nodeDeleted(path);
  }
 } catch(KeeperException e) {
  abortable.abort("Unexpected exception handling nodeCreated event", e);
 }
}

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

/**
 * Starts the tracking of the node in ZooKeeper.
 *
 * <p>Use {@link #blockUntilAvailable()} to block until the node is available
 * or {@link #getData(boolean)} to get the data of the node if it is available.
 */
public synchronized void start() {
 this.watcher.registerListener(this);
 try {
  if(ZKUtil.watchAndCheckExists(watcher, node)) {
   byte [] data = ZKUtil.getDataAndWatch(watcher, node);
   if(data != null) {
    this.data = data;
   } else {
    // It existed but now does not, try again to ensure a watch is set
    LOG.debug("Try starting again because there is no data from " + node);
    start();
   }
  }
 } catch (KeeperException e) {
  abortable.abort("Unexpected exception during initialization, aborting", e);
 }
}

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

/**
 * Checks if the root region location is available.
 * @return true if root region location is available, false if not
 */
public boolean isLocationAvailable() {
 return super.getData(true) != null;
}

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

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

/**
 * Gets the data of the node, blocking until the node is available.
 *
 * @return data of the node
 * @throws InterruptedException if the waiting thread is interrupted
 */
public synchronized byte [] blockUntilAvailable()
throws InterruptedException {
 return blockUntilAvailable(0, false);
}

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

@Override
public synchronized void nodeCreated(String path) {
 if (!path.equals(node)) return;
 try {
  byte [] data = ZKUtil.getDataAndWatch(watcher, node);
  if (data != null) {
   this.data = data;
   notifyAll();
  } else {
   nodeDeleted(path);
  }
 } catch(KeeperException e) {
  abortable.abort("Unexpected exception handling nodeCreated event", e);
 }
}

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

/**
 * Check if there is a master available.
 * @return true if there is a master set, false if not.
 */
public boolean hasMaster() {
 return super.getData(false) != null;
}

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

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

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

/**
 * Utilty method to wait indefinitely on a znode availability while checking
 * if the region server is shut down
 * @param tracker znode tracker to use
 * @throws IOException any IO exception, plus if the RS is stopped
 * @throws InterruptedException
 */
private void blockAndCheckIfStopped(ZooKeeperNodeTracker tracker)
  throws IOException, InterruptedException {
 while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
  if (this.stopped) {
   throw new IOException("Received the shutdown message while waiting.");
  }
 }
}

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

/**
 * Checks if cluster is up.
 * @return true if the cluster up ('shutdown' is its name up in zk) znode
 * exists with data, false if not
 */
public boolean isClusterUp() {
 return super.getData(false) != null;
}

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