Examples of advanceRow()

Examples of org.voltdb.VoltTable.advanceRow()

359
360
361
362
363
364
365
366
367
368
369
        String qs = "select sum(V.SUM_v1), sum(V.SUM_V2) from V";

        vt = client.callProcedure("@AdHoc", qs).getResults()[0];
        System.out.println("testDistributedSum_View result: " + vt);
        assertTrue(vt.getRowCount() == 1);
        while (vt.advanceRow()) {
            Integer sum1 = (Integer) vt.get(0, VoltType.INTEGER);
            assertEquals(2000, sum1.intValue());
            Integer sum2 = (Integer) vt.get(1, VoltType.INTEGER);
            assertEquals(4995000, sum2.intValue());
            // FIXME Integer sum3 = (Integer) vt.get(2, VoltType.INTEGER);
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

393
394
395
396
397
398
399
400
401
402
403
        System.out.println("testDistributedSumAndJoin result: " + vt);
        assert (vt.getRowCount() == 10); // 10 unique values for dim1 which is
        // the grouping col

        int found[] = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
        while (vt.advanceRow()) {
            Integer d1 = (Integer) vt.get(0, VoltType.INTEGER);
            Integer s1 = (Integer) vt.get(1, VoltType.INTEGER);
            Integer s2 = (Integer) vt.get(2, VoltType.INTEGER);
            // FIXME Integer s3 = (Integer) vt.get(3, VoltType.INTEGER);
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

84
85
86
87
88
89
90
91
92
93
94
        assertNotNull(cresponse);
        assertEquals(Status.OK, cresponse.getStatus());
        assertEquals(1, cresponse.getResults().length);
       
        VoltTable vt = cresponse.getResults()[0];
        boolean adv = vt.advanceRow();
        assert(adv);
        assertEquals(key, vt.getLong(0));
    }
   
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

60
61
62
63
64
65
66
67
68
69
70
        List< List<Object>> rtLists = new ArrayList< List< Object >>();
        vt.resetRowPosition();
        Map<Integer,Integer> map = new HashMap<Integer,Integer>();
        //Set <Integer> keyset = new HashSet <Integer>();
        Integer ct = 0;
        while(vt.advanceRow()) {
            Integer key = new Integer ((int) vt.getLong(3));
            if (!map.containsKey(key)) {
                map.put(new Integer ((int) vt.getLong(3)),ct);
                List <Object> cont = new ArrayList<Object>();
                rtLists.add(ct,cont);
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

71
72
73
74
75
76
77
78
79
80
81
        ClientResponse cresponse = getStats(client, SysProcSelector.TABLE);
        VoltTable result = cresponse.getResults()[0];
       
        long count = 0;
        boolean found = false;
        while (result.advanceRow()) {
            if (tbl.getName().equalsIgnoreCase(result.getString("TABLE_NAME"))) {
                found = true;
                count += result.getLong("TUPLE_COUNT");
                if (tbl.getIsreplicated()) break;
            }
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

51
52
53
54
55
56
57
58
59
60
61
            assertEquals(this.table.getRowCount(), sorted.getRowCount());

            System.err.println(sorted);

            Comparable last = null;
            while (sorted.advanceRow()) {
                Comparable cur = (Comparable<?>) sorted.get(sortCol.getFirst());
                if (last != null) {
                    assert (cur.compareTo(last) > 0) : String.format("%s > %s", cur, last);
                }
                last = cur;
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

83
84
85
86
87
88
89
90
91
92
93
            assertEquals(this.table.getRowCount(), sorted.getRowCount());

            System.err.println(sorted);

            Comparable last = null;
            while (sorted.advanceRow()) {
                Comparable cur = (Comparable<?>) sorted.get(sortCol.getFirst());
                if (last != null) {
                    assert (cur.compareTo(last) >= 0) : String.format("%s > %s", cur, last);
                }
                last = cur;
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

275
276
277
278
279
280
281
282
283
284
285
        assertEquals(expectedRows, rowCount);

        // System.out.println("Check table :: \n"+result);

        int i = 0;
        while (result.advanceRow()) {
            assertEquals(i, result.getLong(0));
            assertEquals("name_" + i, result.getString(1));
            assertEquals(i, result.getLong(2));
            assertEquals(new Double(i), result.getDouble(3));
            ++i;
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

174
175
176
177
178
179
180
181
182
183
184
            assertTrue(e.getMessage().contains("CONSTRAINT VIOLATION"));
            assertTrue(e.getCause().getMessage().toUpperCase().contains("UNIQUE"));
            if (!isHSQL()) {
                VoltTable table = ((ConstraintFailureException)e.getCause()).getTuples();
                table.resetRowPosition();
                assertTrue(table.advanceRow());
                assertTrue(java.util.Arrays.equals(stringData, table.getStringAsBytes(2)));
            }
        }
        assertTrue(threwException);
    }
View Full Code Here

Examples of org.voltdb.VoltTable.advanceRow()

274
275
276
277
278
279
280
281
282
283
284
        assertEquals(expectedRows, rowCount);

        // System.out.println("Check table :: \n"+result);

        int i = 0;
        while (result.advanceRow()) {
            assertEquals(i, result.getLong(0));
            assertEquals("name_" + i, result.getString(1));
            assertEquals(i, result.getLong(2));
            assertEquals(new Double(i), result.getDouble(3));
            ++i;
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.