Examples of org.apache.hadoop.hbase.client.Result.sorted()

Class org.apache.hadoop.hbase.client.Result

Examples of org.apache.hadoop.hbase.client.Result.sorted()

org.apache.hadoop.hbase.client.Result.sorted()
Returns a sorted array of KeyValues in this Result.
Note: Sorting is done in place, so the backing array will be sorted after calling this method. @return sorted array of KeyValues

    for (int i = 0; i < regions.length; i++) {
      for (int j = 0; j < rows[i].length; j++) {
        Get get = new Get(rows[i][j]);
        get.addFamily(FAMILY);
        Result result = regions[i].get(get, null);
        byte [] bytes = result.sorted()[0].getValue();
        assertNotNull(bytes);
        assertTrue(Bytes.equals(bytes, rows[i][j]));
      }
      // Close the region and delete the log
      regions[i].close();

View Full Code Here

        Get get = new Get(ROWS[i]);
        get.addFamily(HConstants.CATALOG_FAMILY);
        get.setTimeStamp(TIMESTAMPS[j]);
        Result result = t.get(get);
        int cellCount = 0;
        for(@SuppressWarnings("unused")KeyValue kv : result.sorted()) {
          cellCount++;
        }
        assertTrue(cellCount == 1);
      }
    }

View Full Code Here

      if (!result.isEmpty() || !previousEmpty || i > compactInterval) {
        assertEquals("i=" + i, expectedCount, result.size());
        // TODO this was removed, now what dangit?!
        // search looking for the qualifier in question?
        long timestamp = 0;
        for (KeyValue kv : result.sorted()) {
          if (Bytes.equals(kv.getFamily(), families[0])
            && Bytes.equals(kv.getQualifier(), qualifiers[0])) {
            timestamp = kv.getTimestamp();
          }
        }

View Full Code Here

      Get get = new Get(row);
      for(byte [] family : families) {
        get.addColumn(family, qf);
      }
      Result result = newReg.get(get, null);
      KeyValue [] raw = result.sorted();
      assertEquals(families.length, result.size());
      for(int j=0; j<families.length; j++) {
        assertEquals(0, Bytes.compareTo(row, raw[j].getRow()));
        assertEquals(0, Bytes.compareTo(families[j], raw[j].getFamily()));
        assertEquals(0, Bytes.compareTo(qf, raw[j].getQualifier()));

View Full Code Here

    get = new Get(ROW);
    get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
    get.setMaxVersions(3);
    Result result = incommon.get(get);
    assertEquals(1, result.size());
    long time = Bytes.toLong(result.sorted()[0].getValue());
    assertEquals(time, currentTime);
  }


  /*
   * Assert that returned versions match passed in timestamps and that results

View Full Code Here

    // order.
    get = new Get(ROW);
    get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
    get.setMaxVersions(tss.length);
    Result result = incommon.get(get);
    KeyValue [] kvs = result.sorted();
    assertEquals(kvs.length, tss.length);
    for(int i=0;i<kvs.length;i++) {
      t = Bytes.toLong(kvs[i].getValue());
      assertEquals(tss[i], t);
    }

View Full Code Here

    get = new Get(ROW);
    get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
    get.setTimeRange(0, maxStamp);
    get.setMaxVersions(kvs.length - 1);
    result = incommon.get(get);
    kvs = result.sorted();
    assertEquals(kvs.length, tss.length - 1);
    for(int i=1;i<kvs.length;i++) {
      t = Bytes.toLong(kvs[i-1].getValue());
      assertEquals(tss[i], t);
    }

View Full Code Here

      for (int j = 0; j < rows[i].length; j++) {
        Get get = new Get(rows[i][j]);
        get.addFamily(FAMILY);
        Result result = merged.get(get, null);
        assertEquals(1, result.size());
        byte [] bytes = result.sorted()[0].getValue();
        assertNotNull(Bytes.toStringBinary(rows[i][j]), bytes);
        assertTrue(Bytes.equals(bytes, rows[i][j]));
      }
    }
  }

View Full Code Here

    for (int i = 0; i < regions.length; i++) {
      for (int j = 0; j < rows[i].length; j++) {
        Get get = new Get(rows[i][j]);
        get.addFamily(FAMILY);
        Result result = regions[i].get(get, null);
        byte [] bytes = result.sorted()[0].getValue();
        assertNotNull(bytes);
        assertTrue(Bytes.equals(bytes, rows[i][j]));
      }
      // Close the region and delete the log
      regions[i].close();

View Full Code Here


    byte [] rb = Writables.getBytes(result);
    Result deResult = (Result)Writables.getWritable(rb, new Result());


    assertTrue("results are not equivalent, first key mismatch",
        result.sorted()[0].equals(deResult.sorted()[0]));


    assertTrue("results are not equivalent, second key mismatch",
        result.sorted()[1].equals(deResult.sorted()[1]));


    // Test empty Result

View Full Code Here

0 1 2 3 4 5 6 7

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.