Class and 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.
|
Encoder
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
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
AbstractDeserializationSchema
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
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
Class and Description |
---|
BulkWriter
An encoder that encodes data in a bulk fashion, encoding many records together at a time.
|
BulkWriter.Factory
A factory that creates a
BulkWriter . |
Class and Description |
---|
BulkWriter
An encoder that encodes data in a bulk fashion, encoding many records together at a time.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
AbstractDeserializationSchema
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
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
BulkWriter
An encoder that encodes data in a bulk fashion, encoding many records together at a time.
|
BulkWriter.Factory
A factory that creates a
BulkWriter . |
Class and Description |
---|
BulkWriter
An encoder that encodes data in a bulk fashion, encoding many records together at a time.
|
BulkWriter.Factory
A factory that creates a
BulkWriter . |
Class and Description |
---|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
BulkWriter.Factory
A factory that creates a
BulkWriter . |
Encoder
A
Encoder is used by the streaming file sink to perform the actual writing
of the incoming elements to the files in a bucket. |
Class and Description |
---|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
Class and Description |
---|
AbstractDeserializationSchema
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
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.
|
SerializationSchema
The serialization schema describes how to turn a data object into a different serialized
representation.
|
SimpleStringSchema
Very simple serialization schema for strings.
|
TypeInformationSerializationSchema
A serialization and deserialization schema that uses Flink's serialization stack to
transform typed from and to byte arrays.
|
Class and Description |
---|
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.
|
SerializationSchema
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.