Class RowLockRequest

src/RowLockRequest.java:47–174

Acquires an explicit row lock. Row locks are no longer supported as of HBase 0.96. While they can still be used with earlier HBase versions, attempting to use them with HBase 0.95 and up will cause a UnsupportedOperationException to be thrown. For a description of wh

 * All strings are assumed to use the platform's default charset.
 */
public final class RowLockRequest extends HBaseRpc
  implements HBaseRpc.HasTable, HBaseRpc.HasKey {

  private static final byte[] LOCK_ROW = new byte[] {
    'l', 'o', 'c', 'k', 'R', 'o', 'w'
  };

  /**
   * Constructor.
   * <strong>These byte arrays will NOT be copied.</strong>
   * @param table The table containing the row to lock.
   * @param key The key of the row to lock in that table.
   */
  public RowLockRequest(final byte[] table, final byte[] key) {
    super(table, key);
  }

  /**
   * Constructor.
   * @param table The table containing the row to lock.
   * @param key The key of the row to lock in that table.
   */
  public RowLockRequest(final String table, final String key) {
    this(table.getBytes(), key.getBytes());
  }

  @Override
  byte[] method(final byte unused_server_version) {
    return LOCK_ROW;
  }

  @Override
  public byte[] table() {
    return table;
  }

  @Override
  public byte[] key() {
    return key;
  }

  // ---------------------- //
  // Package private stuff. //
  // ---------------------- //

  private int predictSerializedSize() {
    int size = 0;
    size += 4;  // int:  Number of parameters.
    size += 1;  // byte: Type of the 1st parameter.
    size += 3;  // vint: region name length (3 bytes => max length = 32768).
    size += region.name().length;  // The region name.
    size += 1;  // byte: Type of the 2nd parameter.
    size += 3;  // vint: row key length (3 bytes => max length = 32768).
    size += key.length;  // The row key.
    return size;
  }

  /** Serializes this request.  */