Interface | Description |
---|---|
BulkWriter<T> |
An encoder that encodes data in a bulk fashion, encoding many records together at a time.
|
BulkWriter.Factory<T> |
A factory that creates a
BulkWriter . |
DeserializationSchema<T> |
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 for
DeserializationSchema.open(InitializationContext) method. |
Encoder<IN> |
A
Encoder is used by the streaming file sink to perform the actual writing of the
incoming elements to the files in a bucket. |
SerializationSchema<T> |
The serialization schema describes how to turn a data object into a different serialized
representation.
|
SerializationSchema.InitializationContext |
A contextual information provided for
SerializationSchema.open(InitializationContext) method. |
Class | Description |
---|---|
AbstractDeserializationSchema<T> |
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.
|
RuntimeContextInitializationContextAdapters |
A set of adapters between
RuntimeContext and DeserializationSchema.InitializationContext or SerializationSchema.InitializationContext . |
SimpleStringEncoder<IN> |
A simple
Encoder that uses toString() on the input elements and writes them to
the output bucket file separated by newline. |
SimpleStringSchema |
Very simple serialization schema for strings.
|
TypeInformationSerializationSchema<T> |
A serialization and deserialization schema that uses Flink's serialization stack to transform
typed from and to byte arrays.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.