This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 683ee95 add Boolean type in DefaultSerDe (#1499) 683ee95 is described below commit 683ee9524b6d0c906af554001b5f07589aaaa264 Author: Rajan Dhabalia <rdhaba...@apache.org> AuthorDate: Wed Apr 4 21:17:21 2018 -0700 add Boolean type in DefaultSerDe (#1499) --- .../org/apache/pulsar/functions/api/utils/DefaultSerDe.java | 4 ++++ .../apache/pulsar/functions/api/utils/DefaultSerDeTest.java | 10 ++++++++++ 2 files changed, 14 insertions(+) diff --git a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java index 88e3f60..543823d 100644 --- a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java +++ b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java @@ -59,6 +59,8 @@ public class DefaultSerDe implements SerDe<Object> { return Double.valueOf(data); } else if (type.equals(Long.class)) { return Long.valueOf(data); + } else if (type.equals(Boolean.class)) { + return Boolean.valueOf(data); } else if (type.equals(String.class)) { return data; } else if (type.equals(Short.class)) { @@ -82,6 +84,8 @@ public class DefaultSerDe implements SerDe<Object> { return ((Double) input).toString().getBytes(StandardCharsets.UTF_8); } else if (type.equals(Long.class)) { return ((Long) input).toString().getBytes(StandardCharsets.UTF_8); + } else if (type.equals(Boolean.class)) { + return ((Boolean) input).toString().getBytes(StandardCharsets.UTF_8); } else if (type.equals(String.class)) { return ((String) input).getBytes(StandardCharsets.UTF_8); } else if (type.equals(Short.class)) { diff --git a/pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/DefaultSerDeTest.java b/pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/DefaultSerDeTest.java index 3b1b118..6acb6a1 100644 --- a/pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/DefaultSerDeTest.java +++ b/pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/DefaultSerDeTest.java @@ -53,6 +53,16 @@ public class DefaultSerDeTest { } @Test + public void testBooleanSerDe() { + DefaultSerDe serializer = new DefaultSerDe(Boolean.class); + DefaultSerDe deserializer = new DefaultSerDe(Boolean.class); + Boolean input = Boolean.TRUE; + byte[] output = serializer.serialize(input); + Boolean result = (Boolean) deserializer.deserialize(output); + assertEquals(result, input); + } + + @Test public void testDoubleSerDe() { DefaultSerDe serializer = new DefaultSerDe(Double.class); DefaultSerDe deserializer = new DefaultSerDe(Double.class); -- To stop receiving notification emails like this one, please contact mme...@apache.org.