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

ZoneReencryptionStatus.getFilesReencrypted介绍

暂无

代码示例

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

List<XAttr> completeReencryption(final INode zoneNode) throws IOException {
 assert dir.hasWriteLock();
 assert dir.getFSNamesystem().hasWriteLock();
 final Long zoneId = zoneNode.getId();
 ZoneReencryptionStatus zs = getReencryptionStatus().getZoneStatus(zoneId);
 assert zs != null;
 LOG.info("Re-encryption completed on zone {}. Re-encrypted {} files,"
     + " failures encountered: {}.", zoneNode.getFullPathName(),
   zs.getFilesReencrypted(), zs.getNumReencryptionFailures());
 synchronized (this) {
  submissions.remove(zoneId);
 }
 return FSDirEncryptionZoneOp
   .updateReencryptionFinish(dir, INodesInPath.fromINode(zoneNode), zs);
}

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

.convert(origStatus.getEzKeyVersionName(),
  origStatus.getSubmissionTime(), false,
  origStatus.getFilesReencrypted() + numReencrypted,
  origStatus.getNumReencryptionFailures() + numFailures, null,
  lastFile);

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

Boolean.toString(zs.isCanceled()),
completion == 0 ? "N/A" : Time.formatTime(completion),
Long.toString(zs.getFilesReencrypted()),
Long.toString(zs.getNumReencryptionFailures()),
zs.getLastCheckpointFile());

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

static XAttr generateNewXAttrForReencryptionFinish(final INodesInPath iip,
  final ZoneReencryptionStatus status) throws IOException {
 final ZoneEncryptionInfoProto zoneProto = getZoneEncryptionInfoProto(iip);
 final ReencryptionInfoProto newRiProto = PBHelperClient
   .convert(status.getEzKeyVersionName(), status.getSubmissionTime(),
     status.isCanceled(), status.getFilesReencrypted(),
     status.getNumReencryptionFailures(), Time.now(), null);
 final ZoneEncryptionInfoProto newZoneProto = PBHelperClient
   .convert(PBHelperClient.convert(zoneProto.getSuite()),
     PBHelperClient.convert(zoneProto.getCryptoProtocolVersion()),
     zoneProto.getKeyName(), newRiProto);
 final XAttr xattr = XAttrHelper
   .buildXAttr(CRYPTO_XATTR_ENCRYPTION_ZONE, newZoneProto.toByteArray());
 return xattr;
}

代码示例来源：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

.setSubmissionTime(zs.getSubmissionTime())
  .setCanceled(zs.isCanceled())
  .setNumReencrypted(zs.getFilesReencrypted())
  .setNumFailures(zs.getNumReencryptionFailures());
switch (zs.getState()) {