Package org.apache.hadoop.hbase.client

Examples of org.apache.hadoop.hbase.client.HTable.flushCommits()

374
375
376
377
378
379
380
381
382
383
384
    long ts1 = 10, ts2 = 11, ts3 = 12;
    p.add(FAM, indexed_qualifer, ts1, value1);
    // our group indexes all columns in the this family, so any qualifier here is ok
    p.add(FAM2, regular_qualifer, ts2, value3);
    primary.put(p);
    primary.flushCommits();

    // check to make sure everything we expect is there
    HTable index1 = new HTable(UTIL.getConfiguration(), fam1.getTable());

    // ts1, we just have v1
View Full Code Here
445
446
447
448
449
450
451
452
453
454
455
    Put p = new Put(row1);
    long ts1 = 10, ts2 = 11, ts3 = 12;
    p.add(FAM, indexed_qualifer, ts1, value1);
    p.add(FAM2, regular_qualifer, ts2, value3);
    primary.put(p);
    primary.flushCommits();

    // now build up a delete with a couple different timestamps
    Delete d = new Delete(row1);
    // these deletes don't need to match the exact ts because they cover everything earlier
    d.deleteColumns(FAM, indexed_qualifer, ts2);
View Full Code Here
496
497
498
499
500
501
502
503
504
505
506
    // do a put to the primary table
    Put p = new Put(row1);
    long ts = 12;
    p.add(FAM, indexed_qualifer, ts, value1);
    primary.put(p);
    primary.flushCommits();

    // read the index for the expected values
    HTable index1 = new HTable(UTIL.getConfiguration(), fam1.getTable());

    // build the expected kvs
View Full Code Here
557
558
559
560
561
562
563
564
565
566
567
    long ts1 = 1, ts2 = 2, ts3 = 3, ts4 = 4, ts5 = 5;
    byte[] value4 = Bytes.toBytes("val4");
    byte[] value5 = Bytes.toBytes("val5");
    p.add(FAM2, indexed_qualifer, ts1, value1);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts3, value3);
    primary.put(p);
    primary.flushCommits();
View Full Code Here
562
563
564
565
566
567
568
569
570
571
572
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts3, value3);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts4, value4);
    primary.put(p);
    primary.flushCommits();
View Full Code Here
567
568
569
570
571
572
573
574
575
576
577
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts4, value4);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts5, value5);
    primary.put(p);
    primary.flushCommits();
View Full Code Here
572
573
574
575
576
577
578
579
580
581
582
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM2, indexed_qualifer, ts5, value5);
    primary.put(p);
    primary.flushCommits();

    // read the index for the expected values
    HTable index = new HTable(UTIL.getConfiguration(), fam2.getTable());

    // do a raw scan of everything in the table
View Full Code Here
687
688
689
690
691
692
693
694
695
696
697
    // make some puts to the primary table
    Put p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts1, value1);
    p.add(FAM2, indexed_qualifer, ts1, v1_1);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts3, value3);
    p.add(FAM2, indexed_qualifer, ts3, v3_1);
    primary.put(p);
View Full Code Here
693
694
695
696
697
698
699
700
701
702
703
    p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts3, value3);
    p.add(FAM2, indexed_qualifer, ts3, v3_1);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts5, value5);
    p.add(FAM2, indexed_qualifer, ts5, v5_1);
    primary.put(p);
View Full Code Here
699
700
701
702
703
704
705
706
707
708
709
    p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts5, value5);
    p.add(FAM2, indexed_qualifer, ts5, v5_1);
    primary.put(p);
    primary.flushCommits();

    p = new Put(row1);
    p.add(FAM, indexed_qualifer, ts6, value6);
    p.add(FAM2, indexed_qualifer, ts6, v6_1);
    primary.put(p);
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.