Java 类org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos 实例源码

@Override
public EncryptionZone getEZForPath(String src)
    throws IOException {
  final GetEZForPathRequestProto.Builder builder =
      GetEZForPathRequestProto.newBuilder();
  builder.setSrc(src);
  final GetEZForPathRequestProto req = builder.build();
  try {
    final EncryptionZonesProtos.GetEZForPathResponseProto response =
        rpcProxy.getEZForPath(null, req);
    if (response.hasZone()) {
      return PBHelper.convert(response.getZone());
    } else {
      return null;
    }
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public BatchedEntries<EncryptionZone> listEncryptionZones(long id)
    throws IOException {
  final ListEncryptionZonesRequestProto req =
    ListEncryptionZonesRequestProto.newBuilder()
        .setId(id)
        .build();
  try {
    EncryptionZonesProtos.ListEncryptionZonesResponseProto response =
        rpcProxy.listEncryptionZones(null, req);
    List<EncryptionZone> elements =
        Lists.newArrayListWithCapacity(response.getZonesCount());
    for (EncryptionZoneProto p : response.getZonesList()) {
      elements.add(PBHelper.convert(p));
    }
    return new BatchedListEntries<EncryptionZone>(elements,
        response.getHasMore());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public EncryptionZone getEZForPath(String src)
    throws IOException {
  final GetEZForPathRequestProto.Builder builder =
      GetEZForPathRequestProto.newBuilder();
  builder.setSrc(src);
  final GetEZForPathRequestProto req = builder.build();
  try {
    final EncryptionZonesProtos.GetEZForPathResponseProto response =
        rpcProxy.getEZForPath(null, req);
    if (response.hasZone()) {
      return PBHelper.convert(response.getZone());
    } else {
      return null;
    }
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public BatchedEntries<EncryptionZone> listEncryptionZones(long id)
    throws IOException {
  final ListEncryptionZonesRequestProto req =
    ListEncryptionZonesRequestProto.newBuilder()
        .setId(id)
        .build();
  try {
    EncryptionZonesProtos.ListEncryptionZonesResponseProto response =
        rpcProxy.listEncryptionZones(null, req);
    List<EncryptionZone> elements =
        Lists.newArrayListWithCapacity(response.getZonesCount());
    for (EncryptionZoneProto p : response.getZonesList()) {
      elements.add(PBHelper.convert(p));
    }
    return new BatchedListEntries<EncryptionZone>(elements,
        response.getHasMore());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public EncryptionZone getEZForPath(String src)
    throws IOException {
  final GetEZForPathRequestProto.Builder builder =
      GetEZForPathRequestProto.newBuilder();
  builder.setSrc(src);
  final GetEZForPathRequestProto req = builder.build();
  try {
    final EncryptionZonesProtos.GetEZForPathResponseProto response =
        rpcProxy.getEZForPath(null, req);
    if (response.hasZone()) {
      return PBHelper.convert(response.getZone());
    } else {
      return null;
    }
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public BatchedEntries<EncryptionZone> listEncryptionZones(long id)
    throws IOException {
  final ListEncryptionZonesRequestProto req =
    ListEncryptionZonesRequestProto.newBuilder()
        .setId(id)
        .build();
  try {
    EncryptionZonesProtos.ListEncryptionZonesResponseProto response =
        rpcProxy.listEncryptionZones(null, req);
    List<EncryptionZone> elements =
        Lists.newArrayListWithCapacity(response.getZonesCount());
    for (EncryptionZoneProto p : response.getZonesList()) {
      elements.add(PBHelper.convert(p));
    }
    return new BatchedListEntries<EncryptionZone>(elements,
        response.getHasMore());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public EncryptionZone getEZForPath(String src)
    throws IOException {
  final GetEZForPathRequestProto.Builder builder =
      GetEZForPathRequestProto.newBuilder();
  builder.setSrc(src);
  final GetEZForPathRequestProto req = builder.build();
  try {
    final EncryptionZonesProtos.GetEZForPathResponseProto response =
        rpcProxy.getEZForPath(null, req);
    if (response.hasZone()) {
      return PBHelper.convert(response.getZone());
    } else {
      return null;
    }
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

@Override
public BatchedEntries<EncryptionZone> listEncryptionZones(long id)
    throws IOException {
  final ListEncryptionZonesRequestProto req =
    ListEncryptionZonesRequestProto.newBuilder()
        .setId(id)
        .build();
  try {
    EncryptionZonesProtos.ListEncryptionZonesResponseProto response =
        rpcProxy.listEncryptionZones(null, req);
    List<EncryptionZone> elements =
        Lists.newArrayListWithCapacity(response.getZonesCount());
    for (EncryptionZoneProto p : response.getZonesList()) {
      elements.add(PBHelper.convert(p));
    }
    return new BatchedListEntries<EncryptionZone>(elements,
        response.getHasMore());
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}