Method reverseScanRowsNotColumns

test/TestIntegration.java:1662–1702

Longer reverse scan, checks that qualifier and value are still in lexico order.

()

  /** Longer reverse scan, checks that qualifier and value are still in lexico order. */
  @Test
  public void reverseScanRowsNotColumns() throws Exception {
    client.setFlushInterval(FAST_FLUSH);

    // All puts below should be read in scan
    final PutRequest put1 = new PutRequest(table, "rl1", family, "q1", "v1");
    final PutRequest put2 = new PutRequest(table, "rl1", family, "q2", "v2");
    final PutRequest put3 = new PutRequest(table, "rl2", family, "q3", "v3");
    final PutRequest put4 = new PutRequest(table, "rl2", family, "q4", "v4");
    final PutRequest put5 = new PutRequest(table, "rl3", family, "q5", "v5");
    final PutRequest put6 = new PutRequest(table, "rl3", family, "q6", "v6");

    Deferred.group(Deferred.group(client.put(put1), client.put(put2),
                  client.put(put3)),
          Deferred.group(client.put(put4), client.put(put5),
                  client.put(put6))).join();
    final Scanner rev_scanner = client.newScanner(table);
    rev_scanner.setStartKey("rl9");   // Start key is inclusive
    rev_scanner.setStopKey("rl0");    // Stop key is exclusive
    rev_scanner.setReversed(true);

    final ArrayList<ArrayList<KeyValue>> rev_rows = rev_scanner.nextRows().join();
    rev_scanner.close().join();

    assertSizeIs(3, rev_rows);

    ArrayList<KeyValue> kvs = rev_rows.get(0); // KV from 'rl3'
    assertSizeIs(2, kvs);
    assertEq("v5", kvs.get(0).value());
    assertEq("v6", kvs.get(1).value());

    kvs = rev_rows.get(1); // KV from 'rl2', qualifer and value will still be in lexico order
    assertSizeIs(2, kvs);
    assertEq("v3", kvs.get(0).value());
    assertEq("v4", kvs.get(1).value());

    kvs = rev_rows.get(2);
    assertSizeIs(2, kvs);
    assertEq("v1", kvs.get(0).value());
    assertEq("v2", kvs.get(1).value());
  }


  /** Reverse scans single row and verifies that columns are turned in forward lexico order*/