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

转载 作者：知者 更新时间：2024-03-13 09:44:13 27 4

.convert(origStatus.getEzKeyVersionName(),
  origStatus.getSubmissionTime(), false,
  origStatus.getFilesReencrypted() + numReencrypted,

/**
 * 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()));
}

new ZoneTraverseInfo(zs.getEzKeyVersionName()));
} else {

final long completion = zs.getCompletionTime();
listing.addRow(zs.getZoneName(), zs.getState().toString(),
  zs.getEzKeyVersionName(), Time.formatTime(zs.getSubmissionTime()),
  Boolean.toString(zs.isCanceled()),
  completion == 0 ? "N/A" : Time.formatTime(completion),

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

.setId(zs.getId())
.setPath(zs.getZoneName())
.setEzKeyVersionName(zs.getEzKeyVersionName())
.setSubmissionTime(zs.getSubmissionTime())
.setCanceled(zs.isCanceled())

27 4 0

• hdfs - HDFS 文件如何存储在底层操作系统文件系统上？

  HDFS 是 Hadoop 中的逻辑文件系统，块大小为 64MB。 HDFS 上的文件依次保存在底层操作系统文件系统上，比如 ext4，块大小为 4KiB。 据我所知，对于本地文件系统上的文件，操作系

• hadoop - HDFS 占用空间 : "hdfs dfs -du/" vs "hdfs dfsadmin -report"

  哪种工具最适合测量 HDFS 空间消耗？ 当我总结“hdfs dfs -du/”的输出时，与“hdfs dfsadmin -report”(“DFS Used”行)相比，我总是消耗更少的空间。是否有

• hdfs - 将 HDFS 校验和与本地文件系统校验和进行比较

  我正在尝试编写一个简单的脚本来验证 HDFS 和本地文件系统校验和。 在 HDFS 上我得到 - [m@x01tbipapp3a ~]$ hadoop fs -checksum /user/m/fil

• hdfs - 如何从 HDFS 恢复已删除的文件夹

  我从 HDFS 中删除了一个文件夹，我在下面找到了它 /user/hdfs/.Trash/Current/ 但我无法恢复它。我查看了论坛，但没有找到好的解决方案。 请有人有解决方案我可以帮助我如何在最

• hdfs - Presto hdfs 本地读取和预聚合

  在 5 个节点的集群上运行 Presto 大型扫描查询，看起来只有一个节点是查询协调器，并通过网络从 5 个 hdfs 节点读取数据。 所有 presto 进程都在数据节点上运行。 有没有办法让5个节

• hdfs - 将文件放在名称中有空格的 HDFS 上

  我有一个名为 file name(1).zip 的文件(里面有空格和括号)，我想把这个文件放在 HDFS 上。但是每次我尝试通过 hadoop fs -put ... 放置它时，我都会遇到异常。 我什

• hdfs - Presto hdfs 本地读取和预聚合

  在 5 个节点集群上运行 Presto 大扫描查询，看起来只有一个节点是查询协调器，并通过网络从 5 个 hdfs 节点读取数据。 所有presto进程都在数据节点上运行。 有没有办法让5个节点使用s

• hadoop hdfs 指向文件 :///not hdfs://

  所以我在 CentOS 5 上通过 Cloudera Manager cdh3u5 安装了 Hadoop。当我运行 cmd 时 hadoop fs -ls/ 我希望看到 hdfs://localhos

• hadoop - HDFS 错误 + 不完整的 HDFS URI，没有主机 : hdfs://l27. 0.0.1:9000

  我用命令在hadoop上运行flume flume-ng agent -c conf -f conf/flume-twitter.conf -n TwitterAgent 现在我无法保存推特数据。它显

• hadoop - 在 HDFS 的联邦中将数据从本地磁盘复制到 HDFS

  我使用两台主机(hadoop-coc-1 和 hadoop-coc-2)尝试在其中配置 HDFS 联合。因此，我在两个主机(hadoop-coc-1 和 hadoop-coc-2)中配置了 $ cat

• hadoop - 将大量文件从 hdfs 移动到 hdfs

  我需要将大量文件从一个 hdfs 目录移动(而不是复制)到同一集群中的另一个 hdfs 目录。 我可以使用 distcp，但它似乎有点矫枉过正，因为它正在复制文件(复制它)我只想移动它。两个问题: A

• hadoop - 无法将文件写入 hdfs - 在安全模式下出现错误 hdfs

  当我尝试将文件从我的 本地目录 复制到 HDFS 时，出现以下错误: [cloudera@localhost ~]$ hadoop fs -copyFromLocal hello.txt /user/

• hadoop - HDFS 到 HDFS 完全强制移动文件

  据我所知，在从一个 HDFS 位置移动到另一个位置时，没有直接选项可以覆盖 HDFS 中的文件，复制 cp 可以选择强制执行。我试图找出是否有任何黑客可以做到这一点？ 我们能做的是 hdfs dfs

• hadoop - 如何将数据从一个 HDFS 复制到另一个 HDFS？

  我有两个 HDFS 设置，想将一些表从 HDFS1 复制(而不是迁移或移动)到 HDFS2。如何将数据从一个 HDFS 复制到另一个 HDFS？是否可以通过 Sqoop 或其他命令行实现？ 最佳答案

• hdfs - Kafka Storm HDFS/S3 数据流

  目前尚不清楚您是否可以像在 Flume 中那样在 Kafka 中进行扇出(复制)。 我想让 Kafka 将数据保存到 HDFS 或 S3，并将该数据的副本发送到 Storm 进行实时处理。 Storm

• hdfs - 作为 EMR 步骤运行 HDFS 命令

  如何发出 hdfs 命令作为 EMR 集群中的一个步骤？将步骤添加为 script_runner.jar 任务似乎奇怪地失败了。 最佳答案 使用 command-runner.jar 并调出 bash

• hdfs - 作为 EMR 步骤运行 HDFS 命令

  如何发出 hdfs 命令作为 EMR 集群中的一个步骤？将步骤添加为 script_runner.jar 任务似乎奇怪地失败了。 最佳答案 使用 command-runner.jar 并调出 bash

• hadoop - 尝试更新 HDFS 中的文件时 HDFS 路径发生变化

  我是 Hadoop 和 HDFS 的新手，所以当我从本地 (Ubuntu 10.04) 复制到本地主机上单个节点上的 HDFS 时，可能是我做错了什么。初始副本工作正常，但当我修改我的本地输入文件夹并

• hadoop - 如何更改 hdfs 用户的 HDFS 用户主目录？

  根据我在 Hadoop HDFS 上的实践，我了解到在创建用户 say u1 并尝试将文件从本地文件系统放入 HDFS 时，它会搜索目录 /user/u1 (默认情况下)对 HDFS 文件系统具有写入

• hadoop - HDFS 将本地文件放入 hdfs 但出现 UnresolvedAddressException

  我想将一个 70G 的文件放入 hdfs，所以我使用“put”命令来完成此操作。但是，我得到以下异常。我用相同的命令尝试了小尺寸文件，它有效。有谁知道是什么问题？谢谢! WARN [DataStre