Java 类org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteTableResponse 实例源码

/**
 * Deletes the table but does not block and wait for it be completely removed.
 * You can use Future.get(long, TimeUnit) to wait on the operation to complete.
 * It may throw ExecutionException if there was an error while executing the operation
 * or TimeoutException in case the wait timeout was not long enough to allow the
 * operation to complete.
 *
 * @param desc table descriptor for table
 * @param tableName name of table to delete
 * @throws IOException if a remote or network exception occurs
 * @return the result of the async delete. You can use Future.get(long, TimeUnit)
 *    to wait on the operation to complete.
 */
// TODO: This should be called Async but it will break binary compatibility
private Future<Void> deleteTableAsyncV2(final TableName tableName) throws IOException {
  DeleteTableResponse response = executeCallable(
    new MasterCallable<DeleteTableResponse>(getConnection()) {
      @Override
      public DeleteTableResponse call(int callTimeout) throws ServiceException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setCallTimeout(callTimeout);
        controller.setPriority(tableName);
        DeleteTableRequest req =
            RequestConverter.buildDeleteTableRequest(tableName, ng.getNonceGroup(),ng.newNonce());
        return master.deleteTable(controller,req);
      }
    });
  return new DeleteTableFuture(this, tableName, response);
}

@Override
public DeleteTableResponse deleteTable(RpcController controller,
    DeleteTableRequest request) throws ServiceException {
  try {
    long procId = master.deleteTable(ProtobufUtil.toTableName(
        request.getTableName()), request.getNonceGroup(), request.getNonce());
    return DeleteTableResponse.newBuilder().setProcId(procId).build();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public DeleteTableResponse deleteTable(RpcController controller,
    DeleteTableRequest request) throws ServiceException {
  try {
    master.deleteTable(ProtobufUtil.toTableName(request.getTableName()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteTableResponse.newBuilder().build();
}

@Override
public DeleteTableResponse deleteTable(RpcController controller, DeleteTableRequest request)
throws ServiceException {
  try {
    deleteTable(ProtobufUtil.toTableName(request.getTableName()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteTableResponse.newBuilder().build();
}

@Override
public DeleteTableResponse deleteTable(RpcController controller,
    DeleteTableRequest request) throws ServiceException {
  try {
    master.deleteTable(ProtobufUtil.toTableName(request.getTableName()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteTableResponse.newBuilder().build();
}

@Override
public DeleteTableResponse deleteTable(RpcController controller, DeleteTableRequest request)
throws ServiceException {
  try {
    deleteTable(ProtobufUtil.toTableName(request.getTableName()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteTableResponse.newBuilder().build();
}

public DeleteTableFuture(final HBaseAdmin admin, final TableName tableName,
    final DeleteTableResponse response) {
  super(admin, (response != null && response.hasProcId()) ? response.getProcId() : null);
  this.tableName = tableName;
}