Method reverseMultipleTableScan

test/TestIntegration.java:1772–1812

Reverse scans on two tables with same data.

()

  /** Reverse scans on two tables with same data. */
  @Test
  public void reverseMultipleTableScan() throws Exception{
    client.setFlushInterval(FAST_FLUSH);
    final String table1 = args[0] + "1";
    final String table2 = args[0] + "2";
    createOrTruncateTable(client, table1, family);
    createOrTruncateTable(client, table2, family);
    final PutRequest put2 = new PutRequest(table1, "rmt1", family, "q2", "val0");
    client.put(put2).join();
    final PutRequest put4 = new PutRequest(table2, "rmt2", family, "q1", "val1");
    client.put(put4).join();
    final PutRequest put3 = new PutRequest(table1, "rmt2", family, "q3", "val1");
    client.put(put3).join();
    final PutRequest put1 = new PutRequest(table2, "rmt1", family, "q4", "val0");
    client.put(put1).join();

    final Scanner rev_scanner_1 = client.newScanner(table1);
    rev_scanner_1.setReversed(true);
    rev_scanner_1.setStartKey("rmt3");
    rev_scanner_1.setStopKey("rmt0");

    final Scanner rev_scanner_2 = client.newScanner(table2);
    rev_scanner_2.setReversed(true);
    rev_scanner_2.setStartKey("rmt3");
    rev_scanner_2.setStopKey("rmt0");

    final ArrayList<ArrayList<KeyValue>> table_1_rows = rev_scanner_1.nextRows().join();
    final ArrayList<ArrayList<KeyValue>> table_2_rows = rev_scanner_2.nextRows().join();
    rev_scanner_1.close().join();
    rev_scanner_2.close().join();

    assertSizeIs(2, table_1_rows);
    assertSizeIs(2,table_2_rows);

    // Compares data from both scans, should be the same
    for (int i=0; i<2; i++){
      assertEq("val"+i, table_1_rows.get(1-i).get(0).value());
      assertEq("val"+i, table_2_rows.get(1-i).get(0).value());
    }

  }

  /** Forward scan across two regions */
  @Test