作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZKNodeTracker.blockUntilAvailable()
方法的一些代码示例,展示了ZKNodeTracker.blockUntilAvailable()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKNodeTracker.blockUntilAvailable()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.zookeeper.ZKNodeTracker
类名称:ZKNodeTracker
方法名:blockUntilAvailable
[英]Gets the data of the node, blocking until the node is available.
[中]获取节点的数据,直到节点可用为止。
代码示例来源:origin: apache/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: apache/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(ZKNodeTracker tracker)
throws IOException, InterruptedException {
while (tracker.blockUntilAvailable(this.msgInterval, false) == null) {
if (this.stopped) {
throw new IOException("Received the shutdown message while waiting.");
}
}
}
代码示例来源:origin: org.apache.hbase/hbase-zookeeper
/**
* 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);
}
本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZKNodeTracker.getData()方法的一些代码示例,展示了ZKNodeTracker.getDat
本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZKNodeTracker.blockUntilAvailable()方法的一些代码示例,展示了ZKNodeTr
我是一名优秀的程序员,十分优秀!