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

    famAndQf = KeyValue.parseColumn(COLUMN);
    get.addColumn(famAndQf[0], famAndQf[1]);
    get.setMaxVersions(tss.length);
    Result result = incommon.get(get);
    List<Cell> cells = new ArrayList<Cell>();
    for(KeyValue kv : result.sorted()) {
      cells.add(new Cell(kv.getValue(), kv.getTimestamp()));
    }
    assertEquals(tss.length, cells.size());
    for (int i = 0; i < cells.size(); i++) {
      long ts = Bytes.toLong(cells.get(i).getValue());

View Full Code Here

    get.addColumn(famAndQf[0], famAndQf[1]);
    get.setTimeStamp(tss[0]);
    get.setMaxVersions(cells.size() - 1);
    result = incommon.get(get);
    cells = new ArrayList<Cell>();
    for(KeyValue kv : result.sorted()) {
      cells.add(new Cell(kv.getValue(), kv.getTimestamp()));
    }
    for (int i = 1; i < cells.size(); i++) {
      long ts = Bytes.toLong(cells.get(i).getValue());
      assertEquals(ts, tss[i]);

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

    
    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
    Result r = new Result();
    byte [] b = Writables.getBytes(r);
    Result deserialized = (Result)Writables.getWritable(b, new Result());

View Full Code Here

    assertTrue(Bytes.equals(row, rowA));
    
    // Call sorted() first
    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]));


    // Call raw() first
    deResult = (Result)Writables.getWritable(rb, new Result());

View Full Code Here

    // Call sorted() first
    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]));


    // Call raw() first
    deResult = (Result)Writables.getWritable(rb, new Result());
    assertTrue("results are not equivalent, first key mismatch",
        result.raw()[0].equals(deResult.raw()[0]));

View Full Code Here

        get.addColumn(family, qualifier);
        get.setMaxVersions(numVersions);
        Result result = table.get(get);
        List<Cell> cells = new ArrayList<Cell>();
  if ( ! result.isEmpty() ) {
      for(KeyValue kv : result.sorted()) {
    cells.add(new Cell(kv.getValue(), kv.getTimestamp()));
      }
  }
        return ThriftUtilities.cellFromHBase(cells.toArray(new Cell[0]));
      } catch (IOException e) {

View Full Code Here

        get.setTimeRange(Long.MIN_VALUE, timestamp);
        get.setMaxVersions(numVersions);
        Result result = table.get(get);
  List<Cell> cells = new ArrayList<Cell>();
  if ( ! result.isEmpty() ) {
      KeyValue [] kvs = result.sorted();
      if (kvs != null) {
    for(KeyValue kv : kvs) {
        cells.add(new Cell(kv.getValue(), 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

      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(rows[i][j].toString(), bytes);
        assertTrue(Bytes.equals(bytes, rows[i][j]));
      }
    }
  }

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.