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 |