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

@Override
public void cleanupBulkLoad(RpcController controller,
                            CleanupBulkLoadRequest request,
                            RpcCallback<CleanupBulkLoadResponse> done) {
  try {
    List<BulkLoadObserver> bulkLoadObservers = getBulkLoadObservers();

    if(bulkLoadObservers != null) {
      ObserverContext<RegionCoprocessorEnvironment> ctx =
                                         new ObserverContext<RegionCoprocessorEnvironment>();
      ctx.prepare(env);

      for(BulkLoadObserver bulkLoadObserver : bulkLoadObservers) {
        bulkLoadObserver.preCleanupBulkLoad(ctx, request);
      }
    }

    fs.delete(new Path(request.getBulkToken()), true);
    done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
    ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
}

@Override
public void cleanupBulkLoad(RpcController controller,
                            CleanupBulkLoadRequest request,
                            RpcCallback<CleanupBulkLoadResponse> done) {
  try {
    List<BulkLoadObserver> bulkLoadObservers = getBulkLoadObservers();

    if(bulkLoadObservers != null) {
      ObserverContext<RegionCoprocessorEnvironment> ctx =
                                         new ObserverContext<RegionCoprocessorEnvironment>();
      ctx.prepare(env);

      for(BulkLoadObserver bulkLoadObserver : bulkLoadObservers) {
        bulkLoadObserver.preCleanupBulkLoad(ctx, request);
      }
    }

    fs.delete(new Path(request.getBulkToken()), true);
    done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
    ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
}

@Override
public void cleanupBulkLoad(RpcController controller,
                            CleanupBulkLoadRequest request,
                            RpcCallback<CleanupBulkLoadResponse> done) {
  try {
    getAccessController().preCleanupBulkLoad(env);
    fs.delete(createStagingDir(baseStagingDir,
        getActiveUser(),
        env.getRegion().getTableDesc().getTableName(),
        new Path(request.getBulkToken()).getName()),
        true);
    done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
    ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
}

@Override
public void cleanupBulkLoad(RpcController controller,
                            CleanupBulkLoadRequest request,
                            RpcCallback<CleanupBulkLoadResponse> done) {
  try {
    getAccessController().preCleanupBulkLoad(env);
    fs.delete(createStagingDir(baseStagingDir,
        getActiveUser(),
        env.getRegion().getTableDesc().getTableName(),
        new Path(request.getBulkToken()).getName()),
        true);
    done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
    ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
}

@Override
public void cleanupBulkLoad(RpcController controller,
                            CleanupBulkLoadRequest request,
                            RpcCallback<CleanupBulkLoadResponse> done) {
  try {
    getAccessController().preCleanupBulkLoad(env);
    fs.delete(createStagingDir(baseStagingDir,
        getActiveUser(),
        env.getRegion().getTableDesc().getTableName(),
        new Path(request.getBulkToken()).getName()),
        true);
    done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
    ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
}

/**
 * Authorization security check for
 * SecureBulkLoadProtocol.cleanupBulkLoad()
 * @param ctx the context
 * @param request the request
 * @throws IOException
 */
@Override
public void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
                               CleanupBulkLoadRequest request) throws IOException {
  requireAccess("preCleanupBulkLoad",
      ctx.getEnvironment().getRegion().getTableDesc().getTableName(), Action.CREATE);
}

/**
 * Authorization security check for
 * SecureBulkLoadProtocol.cleanupBulkLoad()
 * @param ctx the context
 * @param request the request
 * @throws IOException
 */
@Override
public void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
                               CleanupBulkLoadRequest request) throws IOException {
  requireAccess("preCleanupBulkLoad",
      ctx.getEnvironment().getRegion().getTableDesc().getTableName(), Action.CREATE);
}

/**
  * Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
  * It can't bypass the default action, e.g., ctx.bypass() won't have effect.
  * @param ctx the environment to interact with the framework and master
  * @throws IOException
  */
void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
                        CleanupBulkLoadRequest request) throws IOException;

/**
  * Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
  * It can't bypass the default action, e.g., ctx.bypass() won't have effect.
  * @param ctx the environment to interact with the framework and master
  * @throws IOException
  */
void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
                        CleanupBulkLoadRequest request) throws IOException;