- Connectors
- Table & SQL Connectors
- Formats
Formats
本文档是 Apache Flink 的旧版本。建议访问 最新的稳定版本。
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 |