Java 类org.apache.hadoop.hbase.protobuf.generated.SecureBulkLoadProtos.SecureBulkLoadHFilesRequest 实例源码

@Override
public void secureBulkLoadHFiles(RpcController controller, SecureBulkLoadHFilesRequest request,
    RpcCallback<SecureBulkLoadHFilesResponse> done) {
  boolean loaded = false;
  Map<byte[], List<Path>> map = null;
  try {
    SecureBulkLoadManager secureBulkLoadManager = this.rsServices.getSecureBulkLoadManager();
    BulkLoadHFileRequest bulkLoadHFileRequest = ConvertSecureBulkLoadHFilesRequest(request);
    map = secureBulkLoadManager.secureBulkLoadHFiles((HRegion) this.env.getRegion(),
        convert(bulkLoadHFileRequest));
    loaded = map != null && !map.isEmpty();
  } catch (IOException e) {
    CoprocessorRpcUtils.setControllerException(controller, e);
  }
  done.run(SecureBulkLoadHFilesResponse.newBuilder().setLoaded(loaded).build());
}

private BulkLoadHFileRequest ConvertSecureBulkLoadHFilesRequest(
    SecureBulkLoadHFilesRequest request) {
  BulkLoadHFileRequest.Builder bulkLoadHFileRequest = BulkLoadHFileRequest.newBuilder();
  RegionSpecifier region =
      ProtobufUtil.buildRegionSpecifier(RegionSpecifierType.REGION_NAME, this.env
          .getRegionInfo().getRegionName());
  bulkLoadHFileRequest.setRegion(region).setFsToken(request.getFsToken())
      .setBulkToken(request.getBulkToken()).setAssignSeqNum(request.getAssignSeqNum())
      .addAllFamilyPath(request.getFamilyPathList());
  return bulkLoadHFileRequest.build();
}