org.apache.flink.streaming.util.serialization

Interface DeserializationSchema<T>

Type Parameters:

T - The type created by the deserialization schema.

All Superinterfaces:

DeserializationSchema<T>, ResultTypeQueryable<T>, Serializable

Deprecated.

Use DeserializationSchema instead.

@Public
 @Deprecated
public interface DeserializationSchema<T>
extends DeserializationSchema<T>, Serializable, ResultTypeQueryable<T>

The deserialization schema describes how to turn the byte messages delivered by certain data sources (for example Apache Kafka) into data types (Java/Scala objects) that are processed by Flink.

Note: In most cases, one should start from AbstractDeserializationSchema, which takes care of producing the return type information automatically.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

DeserializationSchema.InitializationContext

Method Summary

Modifier and Type	Method and Description
T	deserialize(byte[] message) Deprecated. Deserializes the byte message.
boolean	isEndOfStream(T nextElement) Deprecated. Method to decide whether the element signals the end of the stream.

Methods inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

deserialize, open

Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

getProducedType

Method Detail

deserialize

T deserialize(byte[] message)
       throws IOException

Deprecated.

Deserializes the byte message.

Specified by:

deserialize in interface DeserializationSchema<T>

Parameters:

message - The message, as a byte array.

Returns:

The deserialized message as an object (null if the message cannot be deserialized).

Throws:

IOException

isEndOfStream

boolean isEndOfStream(T nextElement)

Deprecated.

Method to decide whether the element signals the end of the stream. If true is returned the element won't be emitted.

Specified by:

isEndOfStream in interface DeserializationSchema<T>

Parameters:

nextElement - The element to test for the end-of-stream signal.

Returns:

True, if the element signals end of stream, false otherwise.