This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.
Flink 提供了一套与表连接器(table connector)一起使用的表格式(table format)。表格式是一种存储格式,定义了如何把二进制数据映射到表的列上。
Flink 支持以下格式:
| Formats |
Supported Connectors |
| CSV |
Apache Kafka,
Upsert Kafka,
Amazon Kinesis Data Streams,
Amazon Kinesis Data Firehose,
Filesystem |
| JSON |
Apache Kafka,
Upsert Kafka,
Amazon Kinesis Data Streams,
Amazon Kinesis Data Firehose,
Filesystem,
Elasticsearch |
| Apache Avro |
Apache Kafka,
Upsert Kafka,
Amazon Kinesis Data Streams,
Amazon Kinesis Data Firehose,
Filesystem |
| Confluent Avro |
Apache Kafka,
Upsert Kafka |
| Debezium CDC |
Apache Kafka,
Filesystem |
| Canal CDC |
Apache Kafka,
Filesystem |
| Maxwell CDC |
Apache Kafka,
Filesystem |
| OGG CDC |
Apache Kafka,
Filesystem |
| Apache Parquet |
Filesystem |
| Apache ORC |
Filesystem |
| Raw |
Apache Kafka,
Upsert Kafka,
Amazon Kinesis Data Streams,
Amazon Kinesis Data Firehose,
Filesystem |