本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZooKeeperNodeTracker.start()
方法的一些代码示例,展示了ZooKeeperNodeTracker.start()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperNodeTracker.start()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.zookeeper.ZooKeeperNodeTracker
类名称:ZooKeeperNodeTracker
方法名:start
[英]Starts the tracking of the node in ZooKeeper.
Use #blockUntilAvailable() to block until the node is available or #getData(boolean) to get the data of the node if it is available.
[中]开始跟踪ZooKeeper中的节点。
使用#blockUntilavable()进行阻塞,直到节点可用,或者使用#getData(布尔值)获取节点的数据(如果可用)。
代码示例来源: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: 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);
}
}
内容来源于网络,如有侵权,请联系作者删除!