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

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

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

DataNode.triggerBlockReport介绍

暂无

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-hdfs

triggerBlockReport(
   new BlockReportOptions.Factory().setIncremental(false).build());
} catch (IOException e) {

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

triggerBlockReport(new BlockReportOptions.Factory()
  .setIncremental(false).build());

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

triggerBlockReport(new BlockReportOptions.Factory()
  .setIncremental(false).build());

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

datanode.triggerBlockReport(
  new BlockReportOptions.Factory().
    setIncremental(incremental).

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

private boolean waitForBlockReport(final DataNode dn,
   final DatanodeDescriptor dnd) throws Exception {
  final DatanodeStorageInfo storage = dnd.getStorageInfos()[0];
  final long lastCount = storage.getBlockReportCount();
  dn.triggerBlockReport(
    new BlockReportOptions.Factory().setIncremental(false).build());
  try {
   GenericTestUtils.waitFor(new Supplier<Boolean>() {
    @Override
    public Boolean get() {
     return lastCount != storage.getBlockReportCount();
    }
   }, 10, 2000);
  } catch (TimeoutException te) {
   return false;
  }
  return true;
 }
}

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

cluster.getDataNodes().get(0).triggerBlockReport(
  new BlockReportOptions.Factory().setIncremental(false).build());

相关文章

DataNode类方法