Package org.apache.flink.streaming.util.serialization

Interface Summary

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 Summary

Class	Description
AbstractDeserializationSchema<T>	Deprecated Use AbstractDeserializationSchema instead.
JSONDeserializationSchema	DeserializationSchema that deserializes a JSON String into an ObjectNode.
JSONKeyValueDeserializationSchema	DeserializationSchema that deserializes a JSON String into an ObjectNode.
JsonRowDeserializationSchema	Deserialization schema from JSON to Row.
JsonRowSerializationSchema	Serialization schema that serializes an object into a JSON bytes.
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.