org.apache.hadoop.hdfs.protocol.ZoneReencryptionStatus.getLastCheckpointFile()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.2k)|赞(0)|评价(0)|浏览(73)

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

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);

相关文章