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

@Override
public TruncateTableResponse truncateTable(RpcController controller, TruncateTableRequest request)
    throws ServiceException {
  try {
    master.truncateTable(
      ProtobufUtil.toTableName(request.getTableName()),
      request.getPreserveSplits(),
      request.getNonceGroup(),
      request.getNonce());
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
  return TruncateTableResponse.newBuilder().build();
}

/**
 * Creates a protocol buffer TruncateTableRequest
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @return a TruncateTableRequest
 */
public static TruncateTableRequest buildTruncateTableRequest(
    final TableName tableName,
    final boolean preserveSplits,
    final long nonceGroup,
    final long nonce) {
  TruncateTableRequest.Builder builder = TruncateTableRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setPreserveSplits(preserveSplits);
  builder.setNonceGroup(nonceGroup);
  builder.setNonce(nonce);
  return builder.build();
}

/**
 * Truncate a table.
 * Synchronous operation.
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void truncateTable(final TableName tableName, final boolean preserveSplits)
    throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      TruncateTableRequest req = RequestConverter.buildTruncateTableRequest(
        tableName, preserveSplits, ng.getNonceGroup(), ng.newNonce());
      master.truncateTable(null, req);
      return null;
    }
  });
}

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

/**
 * Creates a protocol buffer TruncateTableRequest
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @return a TruncateTableRequest
 */
public static TruncateTableRequest buildTruncateTableRequest(final TableName tableName,
      boolean preserveSplits) {
  TruncateTableRequest.Builder builder = TruncateTableRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setPreserveSplits(preserveSplits);
  return builder.build();
}

/**
 * Truncate a table.
 * Synchronous operation.
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @throws IOException if a remote or network exception occurs
 */
@Override
public void truncateTable(final TableName tableName, final boolean preserveSplits)
    throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      TruncateTableRequest req = RequestConverter.buildTruncateTableRequest(
        tableName, preserveSplits);
      master.truncateTable(null, req);
      return null;
    }
  });
}

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

/**
 * Creates a protocol buffer TruncateTableRequest
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @return a TruncateTableRequest
 */
public static TruncateTableRequest buildTruncateTableRequest(final TableName tableName,
      boolean preserveSplits) {
  TruncateTableRequest.Builder builder = TruncateTableRequest.newBuilder();
  builder.setTableName(ProtobufUtil.toProtoTableName(tableName));
  builder.setPreserveSplits(preserveSplits);
  return builder.build();
}

/**
 * Truncate a table.
 * Synchronous operation.
 *
 * @param tableName name of table to truncate
 * @param preserveSplits True if the splits should be preserved
 * @throws IOException if a remote or network exception occurs
 */
public void truncateTable(final TableName tableName, final boolean preserveSplits)
    throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      TruncateTableRequest req = RequestConverter.buildTruncateTableRequest(
        tableName, preserveSplits);
      master.truncateTable(null, req);
      return null;
    }
  });
}