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.

    res = region.get(get, null);
    
    assertEquals(expected.length, res.size());
    for(int i=0; i<res.size(); i++){
      assertEquals(0,
          Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
      assertEquals(0,
          Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
      assertEquals(0,
          Bytes.compareTo(
              expected[i].getQualifier(), res.raw()[i].getQualifier()));

View Full Code Here

    assertEquals(expected.length, res.size());
    for(int i=0; i<res.size(); i++){
      assertEquals(0,
          Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
      assertEquals(0,
          Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
      assertEquals(0,
          Bytes.compareTo(
              expected[i].getQualifier(), res.raw()[i].getQualifier()));
    }

View Full Code Here

          Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
      assertEquals(0,
          Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
      assertEquals(0,
          Bytes.compareTo(
              expected[i].getQualifier(), res.raw()[i].getQualifier()));
    }
    
    //Scan
    Scan scan = new Scan();
    scan.addFamily(HConstants.CATALOG_FAMILY);

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);
  }

View Full Code Here

        new KeyValue(ROW1, FAMILY1, QUALIFIER2, 0, VALUE2));
    List<Result> results = doTestScanHFiles(kvs, new Scan());
    assertEquals(1, results.size());
    Result result = Iterables.getOnlyElement(results);
    assertArrayEquals(ROW1, result.getRow());
    assertEquals(2, result.raw().length);
    assertArrayEquals(VALUE1, result.getColumnLatest(FAMILY1, QUALIFIER1).getValue());
    assertArrayEquals(VALUE2, result.getColumnLatest(FAMILY1, QUALIFIER2).getValue());
  }


  @Test

View Full Code Here


      // Make sure it shows up with an actual timestamp
      Get get = new Get(row).addColumn(fam, qual);
      Result result = region.get(get, null);
      assertEquals(1, result.size());
      KeyValue kv = result.raw()[0];
      LOG.info("Got: " + kv);
      assertTrue("LATEST_TIMESTAMP was not replaced with real timestamp",
          kv.getTimestamp() != HConstants.LATEST_TIMESTAMP);


      // Check same with WAL enabled (historically these took different

View Full Code Here


      // Make sure it shows up with an actual timestamp
      get = new Get(row).addColumn(fam, qual);
      result = region.get(get, null);
      assertEquals(1, result.size());
      kv = result.raw()[0];
      LOG.info("Got: " + kv);
      assertTrue("LATEST_TIMESTAMP was not replaced with real timestamp",
          kv.getTimestamp() != HConstants.LATEST_TIMESTAMP);
    } finally {
      HRegion.closeHRegion(this.region);

View Full Code Here

      //Test
      Result res = region.get(get, null);
      assertEquals(expected.length, res.size());
      for(int i=0; i<res.size(); i++){
        assertEquals(0,
            Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
        assertEquals(0,
            Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
        assertEquals(0,
            Bytes.compareTo(
                expected[i].getQualifier(), res.raw()[i].getQualifier()));

View Full Code Here

      assertEquals(expected.length, res.size());
      for(int i=0; i<res.size(); i++){
        assertEquals(0,
            Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
        assertEquals(0,
            Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
        assertEquals(0,
            Bytes.compareTo(
                expected[i].getQualifier(), res.raw()[i].getQualifier()));
      }

View Full Code Here

            Bytes.compareTo(expected[i].getRow(), res.raw()[i].getRow()));
        assertEquals(0,
            Bytes.compareTo(expected[i].getFamily(), res.raw()[i].getFamily()));
        assertEquals(0,
            Bytes.compareTo(
                expected[i].getQualifier(), res.raw()[i].getQualifier()));
      }


      // Test using a filter on a Get
      Get g = new Get(row1);
      final int count = 2;

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.