Interface | Description |
---|---|
DeserializationSchema<T> | Deprecated
Use
DeserializationSchema instead. |
KeyedDeserializationSchema<T> |
The deserialization schema describes how to turn the byte key / value messages delivered by certain
data sources (for example Apache Kafka) into data types (Java/Scala objects) that are
processed by Flink.
|
KeyedSerializationSchema<T> |
The serialization schema describes how to turn a data object into a different serialized
representation.
|
SerializationSchema<T> | Deprecated
Use
SerializationSchema instead. |
Class | Description |
---|---|
AbstractDeserializationSchema<T> | Deprecated
Use
AbstractDeserializationSchema instead. |
JSONDeserializationSchema | Deprecated
Please use
JsonNodeDeserializationSchema in the "flink-json" module. |
JSONKeyValueDeserializationSchema |
DeserializationSchema that deserializes a JSON String into an ObjectNode.
|
JsonRowDeserializationSchema | Deprecated
Please use
JsonRowDeserializationSchema in
the "flink-json" module. |
JsonRowSerializationSchema | Deprecated
Please use
JsonRowSerializationSchema in
the "flink-json" module. |
KeyedDeserializationSchemaWrapper<T> |
A simple wrapper for using the DeserializationSchema with the KeyedDeserializationSchema
interface.
|
KeyedSerializationSchemaWrapper<T> |
A simple wrapper for using the SerializationSchema with the KeyedDeserializationSchema
interface.
|
SimpleStringSchema | Deprecated
Use
SimpleStringSchema instead. |
TypeInformationKeyValueSerializationSchema<K,V> |
A serialization and deserialization schema for Key Value Pairs that uses Flink's serialization stack to
transform typed from and to byte arrays.
|
TypeInformationSerializationSchema<T> | Deprecated
Use
TypeInformationSerializationSchema instead. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.