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

项目：ditb 文件：HBaseAdmin.java

/**
 * Delete a column from a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param columnName name of column to be deleted
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void deleteColumn(final TableName tableName, final byte [] columnName)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      PayloadCarryingRpcController controller = rpcControllerFactory.newController();
      controller.setCallTimeout(callTimeout);
      controller.setPriority(tableName);
      DeleteColumnRequest req = RequestConverter.buildDeleteColumnRequest(
        tableName, columnName, ng.getNonceGroup(), ng.newNonce());
      master.deleteColumn(controller, req);
      return null;
    }
  });
}

项目：ditb 文件：MasterRpcServices.java

@Override
public DeleteColumnResponse deleteColumn(RpcController controller,
    DeleteColumnRequest req) throws ServiceException {
  try {
    master.deleteColumn(
      ProtobufUtil.toTableName(req.getTableName()),
      req.getColumnName().toByteArray(),
      req.getNonceGroup(),
      req.getNonce());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteColumnResponse.newBuilder().build();
}

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer DeleteColumnRequest
 *
 * @param tableName
 * @param columnName
 * @return a DeleteColumnRequest
 */
public static DeleteColumnRequest buildDeleteColumnRequest(
    final TableName tableName,
    final byte [] columnName,
    final long nonceGroup,
    final long nonce) {
  DeleteColumnRequest.Builder builder = DeleteColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName((tableName)));
  builder.setColumnName(ByteStringer.wrap(columnName));
  builder.setNonceGroup(nonceGroup);
  builder.setNonce(nonce);
  return builder.build();
}

项目：pbase 文件：MasterRpcServices.java

@Override
public DeleteColumnResponse deleteColumn(RpcController controller,
    DeleteColumnRequest req) throws ServiceException {
  try {
    master.deleteColumn(ProtobufUtil.toTableName(req.getTableName()),
      req.getColumnName().toByteArray());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteColumnResponse.newBuilder().build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer DeleteColumnRequest
 *
 * @param tableName
 * @param columnName
 * @return a DeleteColumnRequest
 */
public static DeleteColumnRequest buildDeleteColumnRequest(
    final TableName tableName, final byte [] columnName) {
  DeleteColumnRequest.Builder builder = DeleteColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName((tableName)));
  builder.setColumnName(ByteStringer.wrap(columnName));
  return builder.build();
}

项目：pbase 文件：HBaseAdmin.java

/**
 * Delete a column from a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param columnName name of column to be deleted
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void deleteColumn(final TableName tableName, final byte [] columnName)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      DeleteColumnRequest req = RequestConverter.buildDeleteColumnRequest(tableName, columnName);
      master.deleteColumn(null,req);
      return null;
    }
  });
}

项目：HIndex 文件：HMaster.java

@Override
public DeleteColumnResponse deleteColumn(RpcController controller, DeleteColumnRequest req)
throws ServiceException {
  try {
    deleteColumn(ProtobufUtil.toTableName(req.getTableName()),
        req.getColumnName().toByteArray());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteColumnResponse.newBuilder().build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer DeleteColumnRequest
 *
 * @param tableName
 * @param columnName
 * @return a DeleteColumnRequest
 */
public static DeleteColumnRequest buildDeleteColumnRequest(
    final TableName tableName, final byte [] columnName) {
  DeleteColumnRequest.Builder builder = DeleteColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName((tableName)));
  builder.setColumnName(HBaseZeroCopyByteString.wrap(columnName));
  return builder.build();
}

项目：HIndex 文件：HBaseAdmin.java

/**
 * Delete a column from a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param columnName name of column to be deleted
 * @throws IOException if a remote or network exception occurs
 */
public void deleteColumn(final TableName tableName, final byte [] columnName)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      DeleteColumnRequest req = RequestConverter.buildDeleteColumnRequest(tableName, columnName);
      master.deleteColumn(null,req);
      return null;
    }
  });
}

项目：PyroDB 文件：MasterRpcServices.java

@Override
public DeleteColumnResponse deleteColumn(RpcController controller,
    DeleteColumnRequest req) throws ServiceException {
  try {
    master.deleteColumn(ProtobufUtil.toTableName(req.getTableName()),
      req.getColumnName().toByteArray());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteColumnResponse.newBuilder().build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer DeleteColumnRequest
 *
 * @param tableName
 * @param columnName
 * @return a DeleteColumnRequest
 */
public static DeleteColumnRequest buildDeleteColumnRequest(
    final TableName tableName, final byte [] columnName) {
  DeleteColumnRequest.Builder builder = DeleteColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName((tableName)));
  builder.setColumnName(HBaseZeroCopyByteString.wrap(columnName));
  return builder.build();
}

项目：PyroDB 文件：HBaseAdmin.java

/**
 * Delete a column from a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param columnName name of column to be deleted
 * @throws IOException if a remote or network exception occurs
 */
public void deleteColumn(final TableName tableName, final byte [] columnName)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      DeleteColumnRequest req = RequestConverter.buildDeleteColumnRequest(tableName, columnName);
      master.deleteColumn(null,req);
      return null;
    }
  });
}

项目：c5 文件：HMaster.java

@Override
public DeleteColumnResponse deleteColumn(RpcController controller, DeleteColumnRequest req)
throws ServiceException {
  try {
    deleteColumn(ProtobufUtil.toTableName(req.getTableName()),
        req.getColumnName().toByteArray());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return DeleteColumnResponse.newBuilder().build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer DeleteColumnRequest
 *
 * @param tableName
 * @param columnName
 * @return a DeleteColumnRequest
 */
public static DeleteColumnRequest buildDeleteColumnRequest(
    final TableName tableName, final byte [] columnName) {
  DeleteColumnRequest.Builder builder = DeleteColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName((tableName)));
  builder.setColumnName(ZeroCopyLiteralByteString.wrap(columnName));
  return builder.build();
}

项目：c5 文件：HBaseAdmin.java

/**
 * Delete a column from a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param columnName name of column to be deleted
 * @throws IOException if a remote or network exception occurs
 */
public void deleteColumn(final TableName tableName, final byte [] columnName)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      DeleteColumnRequest req = RequestConverter.buildDeleteColumnRequest(tableName, columnName);
      master.deleteColumn(null,req);
      return null;
    }
  });
}