Class and Description |
---|
KeyedDeserializationSchema
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
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
KeyedDeserializationSchema
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.
|
Class and Description |
---|
KeyedDeserializationSchema
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.
|
Class and Description |
---|
KeyedDeserializationSchema
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
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.