本文档是 Apache Flink 的旧版本。建议访问最新的稳定版本。

v1.11

Home

应用开发
Libraries
Connectors
- DataStream Connectors
  - 概览
  - 容错保证
  - Kafka
  - Cassandra
  - Kinesis
  - Elasticsearch
  - Hadoop FileSystem
  - Streaming File Sink
  - RabbitMQ
  - NiFi
  - Google Cloud PubSub
  - Twitter
  - JDBC
- Table & SQL Connectors
  - 概览
  - Formats
    
    概览
    
    CSV
    
    JSON
    
    Avro
    
    Debezium
    
    Canal
    
    Parquet
    
    Orc
  - Kafka
  - JDBC
  - Elasticsearch
  - FileSystem
  - HBase
  - DataGen
  - Print
  - BlackHole
- DataSet Connectors
部署与运维
调试和监控

Formats

本文档是 Apache Flink 的旧版本。建议访问最新的稳定版本。

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

Flink 支持以下格式：

格式	支持的连接器
CSV	Apache Kafka, Filesystem
JSON	Apache Kafka, Filesystem, Elasticsearch
Apache Avro	Apache Kafka, Filesystem
Debezium CDC	Apache Kafka
Canal CDC	Apache Kafka
Apache Parquet	Filesystem
Apache ORC	Filesystem