Formats

Flink provides a set of table formats that can be used with table connectors. A table format is a storage format that defines how to map binary data onto table columns.

Flink supports the following formats:

FormatsSupported Connectors
CSVApache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem
JSONApache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem, Elasticsearch
Apache AvroApache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem
Confluent AvroApache Kafka, Upsert Kafka
ProtobufApache Kafka
Debezium CDCApache Kafka, Filesystem
Canal CDCApache Kafka, Filesystem
Maxwell CDCApache Kafka, Filesystem
OGG CDCApache Kafka, Filesystem
Apache ParquetFilesystem
Apache ORCFilesystem
RawApache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem