Method reverseScanMoreThanMaxBytes

test/TestIntegration.java:2099–2133

Shows reversed scanner also returns full rows even though max_bytes may be set.

()

  /** Shows reversed scanner also returns full rows even though max_bytes may be set. */
  @Test
  public void reverseScanMoreThanMaxBytes() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    String long_val = "long_str"; // 8 bytes + 1 digit gets added on input
    final PutRequest put1 = new PutRequest(table, "rsmb1", family, "q0", long_val+"0");
    client.put(put1).join();
    final PutRequest put2 = new PutRequest(table, "rsmb1", family, "q1", long_val+"1");
    client.put(put2).join();
    final PutRequest put3 = new PutRequest(table, "rsmb1", family, "q2", long_val+"2");
    client.put(put3).join();
    final PutRequest put4 = new PutRequest(table, "rsmb2", family, "q3", long_val+"3");
    client.put(put4).join();
    final PutRequest put5 = new PutRequest(table, "rsmb2", family, "q4", long_val+"4");
    client.put(put5).join();

    Scanner scanner = client.newScanner(table);
    scanner.setReversed(true);
    scanner.setMaxNumBytes(250); // 250 bytes limit
    scanner.setStartKey("rsmb2");
    scanner.setStopKey("rsmb0");

    // KeyValue size: key is 5 bytes + family: 1 + qualifier: 2 + value:9 + timestamp: 8 = 25 bytes
    // JVM adds around 40 bytes for each object so total is around 65 bytes
    ArrayList<ArrayList<KeyValue>> rows = scanner.nextRows().join();
    scanner.close().join();
    assertSizeIs(2, rows);
    // Even though 5 KVs is more than 250 bytes, we verify that HBase does not
    // truncate rows in the middle
    assertEq(long_val+"3", rows.get(0).get(0).value());
    assertEq(long_val+"4", rows.get(0).get(1).value());
    assertEq(long_val+"0", rows.get(1).get(0).value());
    assertEq(long_val+"1", rows.get(1).get(1).value());
    assertEq(long_val+"2", rows.get(1).get(2).value());

  }

  /**
   * Set a max number of key values to be returned and verify that a reversed scanner