Package org.apache.hadoop.hbase.client

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

121
122
123
124
125
126
127
128
129
130
131
        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
248
249
250
251
252
253
254
255
256
257
258
    if (localGet != null) {
      LOG
          .trace("Transactional get of something we've written in the same transaction "
              + transactionId);

      List<KeyValue> mergedGet = new ArrayList<KeyValue>(Arrays.asList(localGet
          .raw()));

      if (superGet != null && !superGet.isEmpty()) {
        for (KeyValue kv : superGet.raw()) {
          if (!localGet.containsColumn(kv.getFamily(), kv.getQualifier())) {
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
    }
   
    Result oldResult = super.get(oldGet, lockId);
   
    // Add the old values to the new if they are not there
    if (oldResult != null && oldResult.raw() != null) {
      for (KeyValue oldKV : oldResult.raw()) {
        if (!newColumnValues.containsKey(oldKV.getColumn())) {
          newColumnValues.put(oldKV.getColumn(), oldKV.getValue());
        }
      }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
   
    Result oldResult = super.get(oldGet, lockId);
   
    // Add the old values to the new if they are not there
    if (oldResult != null && oldResult.raw() != null) {
      for (KeyValue oldKV : oldResult.raw()) {
        if (!newColumnValues.containsKey(oldKV.getColumn())) {
          newColumnValues.put(oldKV.getColumn(), oldKV.getValue());
        }
      }
    }
View Full Code Here
538
539
540
541
542
543
544
545
546
547
548
    //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
540
541
542
543
544
545
546
547
548
549
550
    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
543
544
545
546
547
548
549
550
551
552
553
          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
597
598
599
600
601
602
603
604
605
606
607
    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
599
600
601
602
603
604
605
606
607
608
609
    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
602
603
604
605
606
607
608
609
610
611
612
          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()));
    }
   
    //flush
    region.flushcache();
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.