org.apache.hadoop.hdfs.server.datanode.DataNode.isDatanodeFullyStarted()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(1.3k)|赞(0)|评价(0)|浏览(99)

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

DataNode.isDatanodeFullyStarted介绍

[英]A datanode is considered to be fully started if all the BP threads are alive and all the block pools are initialized.
[中]如果所有BP线程都处于活动状态且所有块池都已初始化,则认为datanode已完全启动。

代码示例

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

public void waitForNumReplicas(int numReplicas) throws Exception {
  while (UTIL.getDFSCluster().getDataNodes().size() < numReplicas) {
   Thread.sleep(100);
  }

  for (int i = 0; i < numReplicas; ++i) {
   for (DataNode dn: UTIL.getDFSCluster().getDataNodes()) {
    while (!dn.isDatanodeFullyStarted()) {
     Thread.sleep(100);
    }
   }
  }
 }
}

代码示例来源:origin: org.apache.hbase/hbase-server

public void waitForNumReplicas(int numReplicas) throws Exception {
  while (UTIL.getDFSCluster().getDataNodes().size() < numReplicas) {
   Thread.sleep(100);
  }

  for (int i = 0; i < numReplicas; ++i) {
   for (DataNode dn: UTIL.getDFSCluster().getDataNodes()) {
    while (!dn.isDatanodeFullyStarted()) {
     Thread.sleep(100);
    }
   }
  }
 }
}

代码示例来源:origin: ch.cern.hadoop/hadoop-hdfs

if (!dn.datanode.isDatanodeFullyStarted()) {
 LOG.info("!dn.datanode.isDatanodeFullyStarted()");
 return true;

相关文章

DataNode类方法