Examples of runWithCheckedExceptions()

Examples of com.urbanairship.datacube.backfill.HBaseBackfill.runWithCheckedExceptions()

124
125
126
127
128
129
130
131
132
133
134
        };
       
        HBaseBackfill backfill = new HBaseBackfill(getTestUtil().getConfiguration(),
                backfillCallback, LIVE_CUBE_TABLE, SNAPSHOT_TABLE, BACKFILL_TABLE, CF,
                LongOp.LongOpDeserializer.class);
        boolean success = backfill.runWithCheckedExceptions();
        Assert.assertTrue(success);
       
        Assert.assertEquals(0L, cubeWrapper.getHourCount(midnight.plusHours(0)));
        Assert.assertEquals(1L, cubeWrapper.getHourCount(midnight.plusHours(1)));
        Assert.assertEquals(2L, cubeWrapper.getHourCount(midnight.plusHours(2)));
View Full Code Here

Examples of com.urbanairship.datacube.backfill.HBaseBackfillMerger.runWithCheckedExceptions()

90
91
92
93
94
95
96
97
98
99
100
       
        // Since the backfilled table is identical to the snapshot, there should be no changes to the
        // live production table
        HBaseBackfillMerger backfiller = new HBaseBackfillMerger(conf, ArrayUtils.EMPTY_BYTE_ARRAY,
                CUBE_DATA_TABLE, SNAPSHOT_DEST_TABLE, BACKFILLED_TABLE, CF, LongOp.LongOpDeserializer.class);
        Assert.assertTrue(backfiller.runWithCheckedExceptions());
        assertTablesEqual(conf, CUBE_DATA_TABLE, SNAPSHOT_DEST_TABLE);
       
    }

    /**
 
View Full Code Here

Examples of com.urbanairship.datacube.backfill.HBaseBackfillMerger.runWithCheckedExceptions()

122
123
124
125
126
127
128
129
130
131
132
        assertTablesEqual(conf, CUBE_DATA_TABLE, SNAPSHOT_DEST_TABLE);
       
        HBaseBackfillMerger backfiller = new HBaseBackfillMerger(conf, ArrayUtils.EMPTY_BYTE_ARRAY,
                CUBE_DATA_TABLE, SNAPSHOT_DEST_TABLE, BACKFILLED_TABLE, CF,
                LongOp.LongOpDeserializer.class);
        Assert.assertTrue(backfiller.runWithCheckedExceptions());
       
        // After backfilling from an empty "backfilled" table, the live cube should have no rows
        Assert.assertTrue(!new HTable(conf, CUBE_DATA_TABLE).getScanner(CF).iterator().hasNext());
    }
   
View Full Code Here

Examples of com.urbanairship.datacube.backfill.HBaseBackfillMerger.runWithCheckedExceptions()

168
169
170
171
172
173
174
175
176
177
178
        cubeIo.writeSync(new LongOp(7), new WriteBuilder(cube).at(onlyDimension, "coord2"));
       
        HBaseBackfillMerger backfiller = new HBaseBackfillMerger(conf, ArrayUtils.EMPTY_BYTE_ARRAY,
                CUBE_DATA_TABLE, SNAPSHOT_DEST_TABLE, BACKFILLED_TABLE, CF,
                LongOp.LongOpDeserializer.class);
        Assert.assertTrue(backfiller.runWithCheckedExceptions());
       
        // After everyhing's done, the two writes that occurred concurrently with the backfill
        // should be seen in the live table. coord1 should be 5+6=11 and coord2 should be 7.
        Assert.assertEquals(11L,
                cubeIo.get(new ReadBuilder(cube).at(onlyDimension, "coord1")).get().getLong());
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.