本文整理了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
暂无
代码示例来源: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());
内容来源于网络,如有侵权,请联系作者删除!