public class JSONDeserializationSchema extends AbstractDeserializationSchema<com.fasterxml.jackson.databind.node.ObjectNode>
Fields can be accessed by calling objectNode.get(<name>).as(<type>)
Constructor and Description |
---|
JSONDeserializationSchema() |
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.databind.node.ObjectNode |
deserialize(byte[] message)
De-serializes the byte message.
|
boolean |
isEndOfStream(com.fasterxml.jackson.databind.node.ObjectNode nextElement)
Method to decide whether the element signals the end of the stream.
|
getProducedType
public com.fasterxml.jackson.databind.node.ObjectNode deserialize(byte[] message) throws IOException
AbstractDeserializationSchema
deserialize
in interface DeserializationSchema<com.fasterxml.jackson.databind.node.ObjectNode>
deserialize
in class AbstractDeserializationSchema<com.fasterxml.jackson.databind.node.ObjectNode>
message
- The message, as a byte array.IOException
public boolean isEndOfStream(com.fasterxml.jackson.databind.node.ObjectNode nextElement)
AbstractDeserializationSchema
This default implementation returns always false, meaning the stream is interpreted to be unbounded.
isEndOfStream
in interface DeserializationSchema<com.fasterxml.jackson.databind.node.ObjectNode>
isEndOfStream
in class AbstractDeserializationSchema<com.fasterxml.jackson.databind.node.ObjectNode>
nextElement
- The element to test for the end-of-stream signal.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.