Uses of Package
org.apache.flink.api.common.serialization
-
Packages that use org.apache.flink.api.common.serialization Package Description org.apache.flink.api.common.serialization org.apache.flink.api.connector.sink2 -
Classes in org.apache.flink.api.common.serialization used by org.apache.flink.api.common.serialization Class Description BulkWriter An encoder that encodes data in a bulk fashion, encoding many records together at a time.DeserializationSchema 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.DeserializationSchema.InitializationContext A contextual information provided forDeserializationSchema.open(InitializationContext)method.Encoder AEncoderis used by the streaming file sink to perform the actual writing of the incoming elements to the files in a bucket.SerializationSchema The serialization schema describes how to turn a data object into a different serialized representation.SerializationSchema.InitializationContext A contextual information provided forSerializationSchema.open(InitializationContext)method. -
Classes in org.apache.flink.api.common.serialization used by org.apache.flink.api.connector.sink2 Class Description SerializationSchema.InitializationContext A contextual information provided forSerializationSchema.open(InitializationContext)method.