Package org.voltdb

Examples of org.voltdb.ParameterSet.toArray()

75
76
77
78
79
80
81
82
83
84
85
        buf.rewind();

        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));

        assertEquals(3, out.toArray().length);
        assertNull(out.toArray()[0]);
    }

    public void testStrings() throws IOException {
        params.setParameters(new Object[]{"foo"});
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));

        assertEquals(3, out.toArray().length);
        assertNull(out.toArray()[0]);
    }

    public void testStrings() throws IOException {
        params.setParameters(new Object[]{"foo"});
        ByteBuffer buf = ByteBuffer.wrap(FastSerializer.serialize(params));
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        ByteBuffer buf = ByteBuffer.wrap(FastSerializer.serialize(params));
        buf.rewind();

        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));
        assertEquals(1, out.toArray().length);
        assertEquals("foo", out.toArray()[0]);
    }

    public void testStringsAsByteArray() throws IOException {
        params = new ParameterSet();
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        buf.rewind();

        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));
        assertEquals(1, out.toArray().length);
        assertEquals("foo", out.toArray()[0]);
    }

    public void testStringsAsByteArray() throws IOException {
        params = new ParameterSet();
        params.setParameters(new Object[]{new byte[]{'f', 'o', 'o'}});
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
        ByteBuffer buf = ByteBuffer.wrap(FastSerializer.serialize(params));
        buf.rewind();

        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));
        assertEquals(1, out.toArray().length);

        byte[] bin = (byte[]) out.toArray()[0];
        assertEquals(bin[0], 'f'); assertEquals(bin[1], 'o'); assertEquals(bin[2], 'o');
    }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        ParameterSet out = new ParameterSet();
        out.readExternal(new FastDeserializer(buf));
        assertEquals(1, out.toArray().length);

        byte[] bin = (byte[]) out.toArray()[0];
        assertEquals(bin[0], 'f'); assertEquals(bin[1], 'o'); assertEquals(bin[2], 'o');
    }

    private boolean arrayLengthTester(Object[] objs)
    {
View Full Code Here
418
419
420
421
422
423
424
425
426
427
428
        assertNotNull(txn_trace);
       
        ParameterSet params = new ParameterSet(txn_trace.getParams());
        for (ProcParameter catalog_param : catalog_proc.getParameters()) {
            if (catalog_param.getIsarray()) {
                Object inner[] = (Object[])params.toArray()[catalog_param.getIndex()];
                for (int i = 0; i < inner.length; i++) {
                    ParameterMapping pm = new ParameterMapping(catalog_stmt, 0, catalog_stmt_param, catalog_param, i, 1.0d);
                    assertTrue(this.checker.equalParameters(params, pm, params, pm));
                } // FOR
            } else {
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
        assertEquals(2, ft2.getFragmentCount());
        ParameterSet params = null;
        ByteBuffer paramData = ft2.getParameterDataForFragment(0);
        if (paramData != null) {
            params = ParameterSet.fromByteBuffer(paramData);
            assertEquals(10, params.toArray()[0]);
            assertEquals(10.1, params.toArray()[1]);
        }

        params = null;
        paramData = ft2.getParameterDataForFragment(1);
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
        ParameterSet params = null;
        ByteBuffer paramData = ft2.getParameterDataForFragment(0);
        if (paramData != null) {
            params = ParameterSet.fromByteBuffer(paramData);
            assertEquals(10, params.toArray()[0]);
            assertEquals(10.1, params.toArray()[1]);
        }

        params = null;
        paramData = ft2.getParameterDataForFragment(1);
        if (paramData != null) {
View Full Code Here
244
245
246
247
248
249
250
251
252
253
254
        params = null;
        paramData = ft2.getParameterDataForFragment(1);
        if (paramData != null) {
            params = ParameterSet.fromByteBuffer(paramData);
            assertEquals(20, params.toArray()[0]);
            assertEquals(20.2, params.toArray()[1]);
        }
    }

    public void testFragmentTaskWithInitiateTask() throws IOException {
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.