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

项目：ditb 文件：HBaseAdmin.java

/**
 * Add a column to an existing table.
 * Asynchronous operation.
 *
 * @param tableName name of the table to add column to
 * @param column column descriptor of column to be added
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void addColumn(final TableName tableName, final HColumnDescriptor column)
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);
      AddColumnRequest req = RequestConverter.buildAddColumnRequest(
        tableName, column, ng.getNonceGroup(), ng.newNonce());
      master.addColumn(controller,req);
      return null;
    }
  });
}

项目：ditb 文件：MasterRpcServices.java

@Override
public AddColumnResponse addColumn(RpcController controller,
    AddColumnRequest req) throws ServiceException {
  try {
    master.addColumn(
        ProtobufUtil.toTableName(req.getTableName()),
        HColumnDescriptor.convert(req.getColumnFamilies()),
        req.getNonceGroup(),
        req.getNonce());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return AddColumnResponse.newBuilder().build();
}

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer AddColumnRequest
 *
 * @param tableName
 * @param column
 * @return an AddColumnRequest
 */
public static AddColumnRequest buildAddColumnRequest(
    final TableName tableName,
    final HColumnDescriptor column,
    final long nonceGroup,
    final long nonce) {
  AddColumnRequest.Builder builder = AddColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setColumnFamilies(column.convert());
  builder.setNonceGroup(nonceGroup);
  builder.setNonce(nonce);
  return builder.build();
}

项目：pbase 文件：MasterRpcServices.java

@Override
public AddColumnResponse addColumn(RpcController controller,
    AddColumnRequest req) throws ServiceException {
  try {
    master.addColumn(ProtobufUtil.toTableName(req.getTableName()),
      HColumnDescriptor.convert(req.getColumnFamilies()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return AddColumnResponse.newBuilder().build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer AddColumnRequest
 *
 * @param tableName
 * @param column
 * @return an AddColumnRequest
 */
public static AddColumnRequest buildAddColumnRequest(
    final TableName tableName, final HColumnDescriptor column) {
  AddColumnRequest.Builder builder = AddColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setColumnFamilies(column.convert());
  return builder.build();
}

项目：pbase 文件：HBaseAdmin.java

/**
 * Add a column to an existing table.
 * Asynchronous operation.
 *
 * @param tableName name of the table to add column to
 * @param column column descriptor of column to be added
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void addColumn(final TableName tableName, final HColumnDescriptor column)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      AddColumnRequest req = RequestConverter.buildAddColumnRequest(tableName, column);
      master.addColumn(null,req);
      return null;
    }
  });
}

项目：HIndex 文件：HMaster.java

@Override
public AddColumnResponse addColumn(RpcController controller, AddColumnRequest req)
throws ServiceException {
  try {
    addColumn(ProtobufUtil.toTableName(req.getTableName()),
      HColumnDescriptor.convert(req.getColumnFamilies()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return AddColumnResponse.newBuilder().build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer AddColumnRequest
 *
 * @param tableName
 * @param column
 * @return an AddColumnRequest
 */
public static AddColumnRequest buildAddColumnRequest(
    final TableName tableName, final HColumnDescriptor column) {
  AddColumnRequest.Builder builder = AddColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setColumnFamilies(column.convert());
  return builder.build();
}

项目：HIndex 文件：HBaseAdmin.java

/**
 * Add a column to an existing table.
 * Asynchronous operation.
 *
 * @param tableName name of the table to add column to
 * @param column column descriptor of column to be added
 * @throws IOException if a remote or network exception occurs
 */
public void addColumn(final TableName tableName, final HColumnDescriptor column)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      AddColumnRequest req = RequestConverter.buildAddColumnRequest(tableName, column);
      master.addColumn(null,req);
      return null;
    }
  });
}

项目：PyroDB 文件：MasterRpcServices.java

@Override
public AddColumnResponse addColumn(RpcController controller,
    AddColumnRequest req) throws ServiceException {
  try {
    master.addColumn(ProtobufUtil.toTableName(req.getTableName()),
      HColumnDescriptor.convert(req.getColumnFamilies()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return AddColumnResponse.newBuilder().build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer AddColumnRequest
 *
 * @param tableName
 * @param column
 * @return an AddColumnRequest
 */
public static AddColumnRequest buildAddColumnRequest(
    final TableName tableName, final HColumnDescriptor column) {
  AddColumnRequest.Builder builder = AddColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setColumnFamilies(column.convert());
  return builder.build();
}

项目：PyroDB 文件：HBaseAdmin.java

/**
 * Add a column to an existing table.
 * Asynchronous operation.
 *
 * @param tableName name of the table to add column to
 * @param column column descriptor of column to be added
 * @throws IOException if a remote or network exception occurs
 */
public void addColumn(final TableName tableName, final HColumnDescriptor column)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      AddColumnRequest req = RequestConverter.buildAddColumnRequest(tableName, column);
      master.addColumn(null,req);
      return null;
    }
  });
}

项目：c5 文件：HMaster.java

@Override
public AddColumnResponse addColumn(RpcController controller, AddColumnRequest req)
throws ServiceException {
  try {
    addColumn(ProtobufUtil.toTableName(req.getTableName()),
      HColumnDescriptor.convert(req.getColumnFamilies()));
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return AddColumnResponse.newBuilder().build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer AddColumnRequest
 *
 * @param tableName
 * @param column
 * @return an AddColumnRequest
 */
public static AddColumnRequest buildAddColumnRequest(
    final TableName tableName, final HColumnDescriptor column) {
  AddColumnRequest.Builder builder = AddColumnRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setColumnFamilies(column.convert());
  return builder.build();
}

项目：c5 文件：HBaseAdmin.java

/**
 * Add a column to an existing table.
 * Asynchronous operation.
 *
 * @param tableName name of the table to add column to
 * @param column column descriptor of column to be added
 * @throws IOException if a remote or network exception occurs
 */
public void addColumn(final TableName tableName, final HColumnDescriptor column)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      AddColumnRequest req = RequestConverter.buildAddColumnRequest(tableName, column);
      master.addColumn(null,req);
      return null;
    }
  });
}