Package org.apache.s4.serialize

Examples of org.apache.s4.serialize.KryoSerDeser.serialize()

109
110
111
112
113
114
115
116
117
118
119
                .createSerializerDeserializer(Thread.currentThread().getContextClassLoader());
        for (Long message : messages) {
            Event event = new Event();
            event.put("message", long.class, message);
            event.setStreamId("inputStream");
            emitter.send(0, serDeser.serialize(event));
        }

        // check sequential nodes in zk with correct data
        Assert.assertTrue(signalMessagesReceived.await(10, TimeUnit.SECONDS));
        List<String> children = zkClient.getChildren("/test");
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
            keyValueStringField.setAccessible(true);   
            keyValueStringField.set(refPE, "value");
            refPE.setId("statefulPE");
            refPE.setKeys(new String[] {});
            KryoSerDeser kryoSerDeser = new KryoSerDeser();
            byte[] refBytes = kryoSerDeser.serialize(refPE);

            Assert.assertTrue(Arrays.equals(refBytes,
                    TestUtils.readFileAsByteArray(expected)));

            app.destroy();
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.