public class EventDeSerializer extends Object implements DeserializationSchema<Event>, SerializationSchema<Event>
Event
type.Constructor and Description |
---|
EventDeSerializer() |
Modifier and Type | Method and Description |
---|---|
Event |
deserialize(byte[] message)
Deserializes the byte message.
|
TypeInformation<Event> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
boolean |
isEndOfStream(Event nextElement)
Method to decide whether the element signals the end of the stream.
|
byte[] |
serialize(Event evt)
Serializes the incoming element to a specified type.
|
public byte[] serialize(Event evt)
SerializationSchema
serialize
in interface SerializationSchema<Event>
evt
- The incoming element to be serializedpublic Event deserialize(byte[] message) throws IOException
DeserializationSchema
deserialize
in interface DeserializationSchema<Event>
message
- The message, as a byte array.IOException
public boolean isEndOfStream(Event nextElement)
DeserializationSchema
isEndOfStream
in interface DeserializationSchema<Event>
nextElement
- The element to test for the end-of-stream signal.public TypeInformation<Event> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<Event>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.