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

项目：ditb 文件：HBaseAdmin.java

/**
 * Modify an existing column family on a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param descriptor new column descriptor to use
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void modifyColumn(final TableName tableName, final HColumnDescriptor descriptor)
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);
      ModifyColumnRequest req = RequestConverter.buildModifyColumnRequest(
        tableName, descriptor, ng.getNonceGroup(), ng.newNonce());
      master.modifyColumn(controller, req);
      return null;
    }
  });
}

项目：ditb 文件：MasterRpcServices.java

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

项目：ditb 文件：RequestConverter.java

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

项目：pbase 文件：MasterRpcServices.java

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

项目：pbase 文件：RequestConverter.java

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

项目：pbase 文件：HBaseAdmin.java

/**
 * Modify an existing column family on a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param descriptor new column descriptor to use
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void modifyColumn(final TableName tableName, final HColumnDescriptor descriptor)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      ModifyColumnRequest req = RequestConverter.buildModifyColumnRequest(tableName, descriptor);
      master.modifyColumn(null,req);
      return null;
    }
  });
}

项目：HIndex 文件：HMaster.java

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

项目：HIndex 文件：RequestConverter.java

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

项目：HIndex 文件：HBaseAdmin.java

/**
 * Modify an existing column family on a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param descriptor new column descriptor to use
 * @throws IOException if a remote or network exception occurs
 */
public void modifyColumn(final TableName tableName, final HColumnDescriptor descriptor)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      ModifyColumnRequest req = RequestConverter.buildModifyColumnRequest(tableName, descriptor);
      master.modifyColumn(null,req);
      return null;
    }
  });
}

项目：PyroDB 文件：MasterRpcServices.java

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

项目：PyroDB 文件：RequestConverter.java

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

项目：PyroDB 文件：HBaseAdmin.java

/**
 * Modify an existing column family on a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param descriptor new column descriptor to use
 * @throws IOException if a remote or network exception occurs
 */
public void modifyColumn(final TableName tableName, final HColumnDescriptor descriptor)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      ModifyColumnRequest req = RequestConverter.buildModifyColumnRequest(tableName, descriptor);
      master.modifyColumn(null,req);
      return null;
    }
  });
}

项目：c5 文件：HMaster.java

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

项目：c5 文件：RequestConverter.java

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

项目：c5 文件：HBaseAdmin.java

/**
 * Modify an existing column family on a table.
 * Asynchronous operation.
 *
 * @param tableName name of table
 * @param descriptor new column descriptor to use
 * @throws IOException if a remote or network exception occurs
 */
public void modifyColumn(final TableName tableName, final HColumnDescriptor descriptor)
throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      ModifyColumnRequest req = RequestConverter.buildModifyColumnRequest(tableName, descriptor);
      master.modifyColumn(null,req);
      return null;
    }
  });
}