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

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

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

org.apache.hadoop.hbase.client.Result.raw()
Return an cells of a Result as an array of KeyValues WARNING do not use, expensive. This does an arraycopy of the cell[]'s value. Added to ease transition from 0.94 -> 0.96. @deprecated as of 0.96, use {@link #rawCells()} @return array of KeyValues, empty array if nothing in result.

      get.setMaxVersions();
      get.addColumn(fam1,qual1);


      Result r = region.get(get, null);
      assertEquals(2, r.size());
      KeyValue first = r.raw()[0];
      KeyValue second = r.raw()[1];


      assertTrue("ICV failed to upgrade timestamp",
          first.getTimestamp() != second.getTimestamp());
    } finally {

View Full Code Here

      get.addColumn(fam1,qual1);


      Result r = region.get(get, null);
      assertEquals(2, r.size());
      KeyValue first = r.raw()[0];
      KeyValue second = r.raw()[1];


      assertTrue("ICV failed to upgrade timestamp",
          first.getTimestamp() != second.getTimestamp());
    } finally {
      HRegion.closeHRegion(this.region);

View Full Code Here

    Get get = new Get(row);
    get.addColumn(familiy, qualifier);
    Result result = region.get(get, null);
    assertEquals(1, result.size());


    KeyValue kv = result.raw()[0];
    long r = Bytes.toLong(kv.getValue());
    assertEquals(amount, r);
  }


  private void assertICV(byte [] row,

View Full Code Here

    Get get = new Get(row);
    get.addColumn(familiy, qualifier);
    Result result = region.get(get, null);
    assertEquals(1, result.size());


    KeyValue kv = result.raw()[0];
    int r = Bytes.toInt(kv.getValue());
    assertEquals(amount, r);
  }


  public void testScanner_Wildcard_FromMemStoreAndFiles_EnforceVersions()

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.raw()) {
            if (Bytes.equals(kv.getFamily(), families[0])
                && Bytes.equals(kv.getQualifier(), qualifiers[0])) {
              timestamp = kv.getTimestamp();
            }
          }

View Full Code Here

          }
          assertTrue(timestamp >= prevTimestamp);
          prevTimestamp = timestamp;
          KeyValue previousKV = null;


          for (KeyValue kv : result.raw()) {
            byte[] thisValue = kv.getValue();
            if (previousKV != null) {
              if (Bytes.compareTo(previousKV.getValue(), thisValue) != 0) {
                LOG.warn("These two KV should have the same value." +
                    " Previous KV:" +

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.raw();
      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

    // verify the data was copied into table 2
    for (int i = 0; i < 10; i++) {
      Get g = new Get(Bytes.toBytes("row" + i));
      Result r = t2.get(g);
      assertEquals(1, r.size());
      assertTrue(Bytes.equals(COLUMN1, r.raw()[0].getQualifier()));
    }


    t1.close();
    t2.close();
    TEST_UTIL.deleteTable(TABLENAME1);

View Full Code Here

    // verify the data was copied into table 2
    // row1 exist, row0, row2 do not exist
    Get g = new Get(ROW1);
    Result r = t2.get(g);
    assertEquals(1, r.size());
    assertTrue(Bytes.equals(COLUMN1, r.raw()[0].getQualifier()));
    
    g = new Get(ROW0);
    r = t2.get(g);
    assertEquals(0, r.size());

View Full Code Here

    Scan s = new Scan();
    s.setMaxVersions();
    s.setRaw(true);
    ResultScanner scanner = t.getScanner(s);
    Result r = scanner.next();
    KeyValue[] res = r.raw();
    assertTrue(res[0].isDeleteFamily());
    assertEquals(now+4, res[1].getTimestamp());
    assertEquals(now+3, res[2].getTimestamp());
    assertTrue(res[3].isDelete());
    assertEquals(now+2, res[4].getTimestamp());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.