gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-13 09:44:39 27 4
gpt4 key购买 nike

本文整理了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);

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com