Formats
Flink 提供了一套与表连接器(table connector)一起使用的表格式(table format)。表格式是一种存储格式,定义了如何把二进制数据映射到表的列上。
Flink 支持以下格式:
| 格式 | 支持的连接器 |
|---|---|
| CSV | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Filesystem |
| JSON | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Filesystem, Elasticsearch |
| Apache Avro | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Filesystem |
| Confluent Avro | Apache Kafka, Upsert Kafka |
| Debezium CDC | Apache Kafka, Filesystem |
| Canal CDC | Apache Kafka, Filesystem |
| Maxwell CDC | Apache Kafka, Filesystem |
| Apache Parquet | Filesystem |
| Apache ORC | Filesystem |
| Raw | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Filesystem |