gpt4 book ai didi

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

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

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

ZoneReencryptionStatus.getNumReencryptionFailures介绍

暂无

代码示例

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

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

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

completion == 0 ? "N/A" : Time.formatTime(completion),
  Long.toString(zs.getFilesReencrypted()),
  Long.toString(zs.getNumReencryptionFailures()),
  zs.getLastCheckpointFile());
if (zs.getNumReencryptionFailures() > 0) {
 failuresMet = true;

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

.setCanceled(zs.isCanceled())
  .setNumReencrypted(zs.getFilesReencrypted())
  .setNumFailures(zs.getNumReencryptionFailures());
switch (zs.getState()) {
case Submitted:

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