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

ZoneReencryptionStatus.getState介绍

暂无

代码示例

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

private void checkMoveValidityForReencryption(final String pathName,
  final long zoneId) throws IOException {
 assert dir.hasReadLock();
 final ZoneReencryptionStatus zs = reencryptionStatus.getZoneStatus(zoneId);
 if (zs != null && zs.getState() != ZoneReencryptionStatus.State.Completed) {
  final StringBuilder sb = new StringBuilder(pathName);
  sb.append(" can't be moved because encryption zone ");
  sb.append(getFullPathName(zoneId));
  sb.append(" is currently under re-encryption");
  throw new IOException(sb.toString());
 }
}

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

void cancelZone(final long zoneId, final String zoneName) throws IOException {
 assert dir.hasWriteLock();
 final ZoneReencryptionStatus zs =
   getReencryptionStatus().getZoneStatus(zoneId);
 if (zs == null || zs.getState() == State.Completed) {
  throw new IOException("Zone " + zoneName + " is not under re-encryption");
 }
 zs.cancel();
 removeZoneTrackerStopTasks(zoneId);
}

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

ZoneReencryptionStatus zs = it.next();
final long completion = zs.getCompletionTime();
listing.addRow(zs.getZoneName(), zs.getState().toString(),
  zs.getEzKeyVersionName(), Time.formatTime(zs.getSubmissionTime()),
  Boolean.toString(zs.isCanceled()),

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

public Long getNextUnprocessedZone() {
 for (Map.Entry<Long, ZoneReencryptionStatus> entry : zoneStatuses
   .entrySet()) {
  if (entry.getValue().getState() == State.Submitted) {
   return entry.getKey();
  }
 }
 return null;
}

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

public boolean hasRunningZone(final Long zoneId) {
 return zoneStatuses.containsKey(zoneId)
   && zoneStatuses.get(zoneId).getState() != State.Completed;
}

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

@VisibleForTesting
public int zonesQueued() {
 int ret = 0;
 for (Map.Entry<Long, ZoneReencryptionStatus> entry : zoneStatuses
   .entrySet()) {
  if (entry.getValue().getState() == State.Submitted) {
   ret++;
  }
 }
 return ret;
}

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

.setNumReencrypted(zs.getFilesReencrypted())
  .setNumFailures(zs.getNumReencryptionFailures());
switch (zs.getState()) {
case Submitted:
 builder.setState(ReencryptionStateProto.SUBMITTED);
 break;
default:
 throw new IllegalArgumentException("Unknown state " + zs.getState());