概览--流式计算 Flink版-火山引擎

文档中心

导航

概览

最近更新时间：2024.08.20 19:34:51首次发布时间：2024.08.20 19:34:51

Flink 提供了一套与表连接器（table connector）一起使用的表格式（table format）。表格式是一种存储格式，定义了如何把二进制数据映射到表的列上。

Flink 支持格式

概览

Formats	Supported Connectors	Flink版本支持
CSV	Kafka/BMQ Upsert Kafka Filesystem	1.11, 1.16
JSON	Kafka/BMQ Upsert Kafka Filesystem Elasticsearch Redis Pulsar	1.11, 1.16
Debezium-JSON	Kafka/BMQ Filesystem	1.11, 1.16
Canal-JSON	Kafka/BMQ Filesystem	1.11, 1.16
Maxwell-JSON	Kafka/BMQ Filesystem	1.16
Ogg-JSON	Kafka/BMQ Filesystem	1.16
Avro	Kafka/BMQ Upsert Kafka Filesystem Pulsar	1.16
Confluent Avro	Kafka/BMQ Upsert Kafka Filesystem	1.16
Protobuf	Kafka/BMQ Redis	1.16
Parquet	Filesystem	1.11, 1.16
ORC	Filesystem	1.11, 1.16
Raw	Kafka/BMQ Upsert Kafka Filesystem	1.16

版本详情

Flink1.16 支持格式

Formats	Supported Connectors
CSV	Kafka/BMQ Upsert Kafka Filesystem
JSON	Kafka/BMQ Upsert Kafka Filesystem Elasticsearch Redis Pulsar
Debezium-JSON	Kafka/BMQ Filesystem
Canal-JSON	Kafka/BMQ Filesystem
Maxwell-JSON	Kafka/BMQ Filesystem
Ogg-JSON	Kafka/BMQ Filesystem
Avro	Kafka/BMQ Upsert Kafka Filesystem Pulsar
Confluent Avro	Kafka/BMQ Upsert Kafka Filesystem
Protobuf	Kafka/BMQ Redis
Parquet	Filesystem
ORC	Filesystem
Raw	Kafka/BMQ Upsert Kafka Filesystem

Flink1.11 支持格式

Formats	Supported Connectors
CSV	Kafka/BMQ Filesystem
JSON	Kafka/BMQ Filesystem Elasticsearch
Debezium-JSON	Kafka/BMQ Filesystem
Canal-JSON	Kafka/BMQ Filesystem
Parquet	Filesystem
ORC	Filesystem