Package org.apache.hadoop.hbase.client

Examples of org.apache.hadoop.hbase.client.Scan.addColumn()

1627
1628
1629
1630
1631
1632
1633
1634
1635
1636
1637
      assertEquals(1, r.size());
      assertArrayEquals(value2, r.getValue(fam1, qual1));

      // next:
      Scan scan = new Scan(row);
      scan.addColumn(fam1, qual1);
      InternalScanner s = region.getScanner(scan);

      List<Cell> results = new ArrayList<Cell>();
      assertEquals(false, s.next(results));
      assertEquals(1, results.size());
View Full Code Here
2111
2112
2113
2114
2115
2116
2117
2118
2119
2120
2121
      List<Cell> expected = new ArrayList<Cell>();
      expected.add(kv13);
      expected.add(kv12);

      Scan scan = new Scan(row1);
      scan.addColumn(fam1, qf1);
      scan.setMaxVersions(MAX_VERSIONS);
      List<Cell> actual = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);

      boolean hasNext = scanner.next(actual);
View Full Code Here
2173
2174
2175
2176
2177
2178
2179
2180
2181
2182
2183
      expected.add(kv12);
      expected.add(kv23);
      expected.add(kv22);

      Scan scan = new Scan(row1);
      scan.addColumn(fam1, qf1);
      scan.addColumn(fam1, qf2);
      scan.setMaxVersions(MAX_VERSIONS);
      List<Cell> actual = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);
View Full Code Here
2174
2175
2176
2177
2178
2179
2180
2181
2182
2183
2184
      expected.add(kv23);
      expected.add(kv22);

      Scan scan = new Scan(row1);
      scan.addColumn(fam1, qf1);
      scan.addColumn(fam1, qf2);
      scan.setMaxVersions(MAX_VERSIONS);
      List<Cell> actual = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);

      boolean hasNext = scanner.next(actual);
View Full Code Here
2254
2255
2256
2257
2258
2259
2260
2261
2262
2263
2264
      expected.add(kv24);
      expected.add(kv23);
      expected.add(kv22);

      Scan scan = new Scan(row1);
      scan.addColumn(fam1, qf1);
      scan.addColumn(fam1, qf2);
      int versions = 3;
      scan.setMaxVersions(versions);
      List<Cell> actual = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);
View Full Code Here
2255
2256
2257
2258
2259
2260
2261
2262
2263
2264
2265
      expected.add(kv23);
      expected.add(kv22);

      Scan scan = new Scan(row1);
      scan.addColumn(fam1, qf1);
      scan.addColumn(fam1, qf2);
      int versions = 3;
      scan.setMaxVersions(versions);
      List<Cell> actual = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);
View Full Code Here
2432
2433
2434
2435
2436
2437
2438
2439
2440
2441
2442
      put.add(family, col1, Bytes.toBytes(40L));
      region.put(put);

      Scan scan = new Scan(row3, row4);
      scan.setMaxVersions();
      scan.addColumn(family, col1);
      InternalScanner s = region.getScanner(scan);

      List<Cell> results = new ArrayList<Cell>();
      assertEquals(false, s.next(results));
      assertEquals(0, results.size());
View Full Code Here
4310
4311
4312
4313
4314
4315
4316
4317
4318
4319
4320
      put = new Put(rowE);
      put.add(kv5);
      region.put(put);
      region.flushcache();
      Scan scan = new Scan(rowD, rowA);
      scan.addColumn(families[0], col1);
      scan.setReversed(true);
      List<Cell> currRow = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);
      boolean hasNext = scanner.next(currRow);
      assertEquals(1, currRow.size());
View Full Code Here
4331
4332
4333
4334
4335
4336
4337
4338
4339
4340
4341
      assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
      assertFalse(hasNext);
      scanner.close();

      scan = new Scan(rowD, rowA);
      scan.addColumn(families[0], col2);
      scan.setReversed(true);
      currRow.clear();
      scanner = region.getScanner(scan);
      hasNext = scanner.next(currRow);
      assertEquals(1, currRow.size());
View Full Code Here
4389
4390
4391
4392
4393
4394
4395
4396
4397
4398
4399
      put = new Put(rowE);
      put.add(kv5);
      region.put(put);
      region.flushcache();
      Scan scan = new Scan(rowD, rowA);
      scan.addColumn(families[0], col1);
      scan.setReversed(true);
      List<Cell> currRow = new ArrayList<Cell>();
      InternalScanner scanner = region.getScanner(scan);
      boolean hasNext = scanner.next(currRow);
      assertEquals(1, currRow.size());
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.