本文整理了Java中org.apache.hadoop.hdfs.protocol.ZoneReencryptionStatus.getLastCheckpointFile()
方法的一些代码示例,展示了ZoneReencryptionStatus.getLastCheckpointFile()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZoneReencryptionStatus.getLastCheckpointFile()
方法的具体详情如下:
包路径:org.apache.hadoop.hdfs.protocol.ZoneReencryptionStatus
类名称:ZoneReencryptionStatus
方法名:getLastCheckpointFile
暂无
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
/**
* Restore the re-encryption from the progress inside ReencryptionStatus.
* This means start from exactly the lastProcessedFile (LPF), skipping all
* earlier paths in lexicographic order. Lexicographically-later directories
* on the LPF parent paths are added to subdirs.
*/
private void restoreFromLastProcessedFile(final long zoneId,
final ZoneReencryptionStatus zs)
throws IOException, InterruptedException {
final INodeDirectory parent;
final byte[] startAfter;
final INodesInPath lpfIIP =
dir.getINodesInPath(zs.getLastCheckpointFile(), FSDirectory.DirOp.READ);
parent = lpfIIP.getLastINode().getParent();
startAfter = lpfIIP.getLastINode().getLocalNameBytes();
traverser.traverseDir(parent, zoneId, startAfter,
new ZoneTraverseInfo(zs.getEzKeyVersionName()));
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
if (zs.getLastCheckpointFile() == null) {
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
Long.toString(zs.getFilesReencrypted()),
Long.toString(zs.getNumReencryptionFailures()),
zs.getLastCheckpointFile());
if (zs.getNumReencryptionFailures() > 0) {
failuresMet = true;
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs-client
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
for (Map.Entry<Long, ZoneReencryptionStatus> entry : zoneStatuses
.entrySet()) {
sb.append("[zone:" + entry.getKey());
sb.append(" state:" + entry.getValue().getState());
sb.append(" lastProcessed:" + entry.getValue().getLastCheckpointFile());
sb.append(" filesReencrypted:" + entry.getValue().getFilesReencrypted());
sb.append(" fileReencryptionFailures:" + entry.getValue()
.getNumReencryptionFailures() + "]");
}
return sb.toString();
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs-client
builder.setCompletionTime(completion);
final String file = zs.getLastCheckpointFile();
if (file != null) {
builder.setLastFile(file);
内容来源于网络,如有侵权,请联系作者删除!