T
- The type created by the deserialization schema.@PublicEvolving public abstract class AbstractDeserializationSchema<T> extends Object implements DeserializationSchema<T>
This base variant of the deserialization schema produces the type information automatically by extracting it from the generic class arguments.
Constructor and Description |
---|
AbstractDeserializationSchema() |
Modifier and Type | Method and Description |
---|---|
abstract T |
deserialize(byte[] message)
De-serializes the byte message.
|
TypeInformation<T> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
boolean |
isEndOfStream(T nextElement)
Method to decide whether the element signals the end of the stream.
|
public abstract T deserialize(byte[] message) throws IOException
deserialize
in interface DeserializationSchema<T>
message
- The message, as a byte array.IOException
public boolean isEndOfStream(T nextElement)
This default implementation returns always false, meaning the stream is interpreted to be unbounded.
isEndOfStream
in interface DeserializationSchema<T>
nextElement
- The element to test for the end-of-stream signal.public TypeInformation<T> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<T>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.