Method setupValues

test/core/TestSaltScanner.java:490–555

This method sets up some row keys and values to pass to the scanners. The values aren't exactly what would normally be passed to a salt scanner in that we have the same series salted across separate buckets. That would only happen if you add the timestamp to the salt calculation, which we may do in

()

   * may do in the future. We're testing now for future proofing.
   */
  protected void setupValues() throws Exception {
    setDataPointStorage();
    kvs_a = new ArrayList<ArrayList<ArrayList<KeyValue>>>(3);
    kvs_b = new ArrayList<ArrayList<ArrayList<KeyValue>>>(2);
    
    final String note = "{\"tsuid\":\"000001000001000001\","
        + "\"startTime\":1356998490,\"endTime\":0,\"description\":"
        + "\"The Great A'Tuin!\",\"notes\":\"Millenium hand and shrimp\","
        + "\"custom\":null}";
    
    for (int i = 0; i < 5; i++) {
      final ArrayList<ArrayList<KeyValue>> rows = 
          new ArrayList<ArrayList<KeyValue>>(1);
      final ArrayList<KeyValue> row = new ArrayList<KeyValue>(2);
      rows.add(row);
      byte[] key = null;
      
      switch (i) {
      case 0:
        row.add(new KeyValue(KEY_A, FAMILY, QUALIFIER_A, 0, VALUE));
        kvs_a.add(rows);
        break;
      case 1:
        row.add(new KeyValue(KEY_B, FAMILY, QUALIFIER_A, 0, VALUE));
        kvs_a.add(rows);
        break;
      case 2:
        row.add(new KeyValue(KEY_C, FAMILY, QUALIFIER_A, 0, VALUE));
        kvs_a.add(rows);
        break;
      case 3:
        key = Arrays.copyOf(KEY_A, KEY_A.length);
        row.add(new KeyValue(key, FAMILY, QUALIFIER_B, 0, VALUE));
        row.add(new KeyValue(key, FAMILY, new byte[] { 1, 0, 0 }, 0, 
            note.getBytes(Charset.forName("UTF8"))));
        kvs_b.add(rows);
        break;
      case 4:
        key = Arrays.copyOf(KEY_C, KEY_C.length);
        row.add(new KeyValue(key, FAMILY, QUALIFIER_B, 0, VALUE));
        kvs_b.add(rows);
        break;
      }
    }
    
    if (Const.SALT_WIDTH() > 0) {
      when(scanner_a.nextRows())
        .thenReturn(Deferred.fromResult(kvs_a.get(0)))
        .thenReturn(Deferred.fromResult(kvs_a.get(1)))
        .thenReturn(Deferred.fromResult(kvs_a.get(2)))
        .thenReturn(Deferred.<ArrayList<ArrayList<KeyValue>>>fromResult(null));
      
      when(scanner_b.nextRows())
        .thenReturn(Deferred.fromResult(kvs_b.get(0)))
        .thenReturn(Deferred.fromResult(kvs_b.get(1)))
        .thenReturn(Deferred.<ArrayList<ArrayList<KeyValue>>>fromResult(null));
    } else {
      when(scanner_a.nextRows())