Class AbstractDeserializationSchema<T>
- java.lang.Object
-
- org.apache.flink.api.common.serialization.AbstractDeserializationSchema<T>
-
- org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema<T>
-
- Type Parameters:
T- The type created by the deserialization schema.
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.serialization.DeserializationSchema<T>,org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>,DeserializationSchema<T>
@Deprecated @PublicEvolving public abstract class AbstractDeserializationSchema<T> extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<T> implements DeserializationSchema<T>
Deprecated.UseAbstractDeserializationSchemainstead.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.This base variant of the deserialization schema produces the type information automatically by extracting it from the generic class arguments.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AbstractDeserializationSchema()Deprecated.
-
Method Summary
-
Methods inherited from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema
deserialize, getProducedType, isEndOfStream
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema
deserialize, open
-
Methods inherited from interface org.apache.flink.streaming.util.serialization.DeserializationSchema
deserialize, isEndOfStream
-
-