Table SQL connectors以及FileSystem、JDBC connector

目录

Flink支持的连接器

 如何使用连接器 

FileSystem SQL Connector

 文件格式

分区文件

Source

目录监控

 元数据

Streaming Sink

滚动策略

文件合并

JDBC SQL Connector

依赖

如何创建JDBC表

连接器配置

案例

pom依赖

代码

测试

---

        Flink的Table API和SQL程序可以连接到其他外部系统，用于读取和写入批处理和流表（ batch and streaming tables）。表源（Table Source）提供对存储在外部系统（如数据库、键值存储、消息队列或文件系统)中的数据的访问。表接收器（Table Sink）将表发送到外部存储系统。根据源和接收的类型，它们支持不同的格式，如CSV、Avro、Parquet或ORC。

Flink支持的连接器

        Flink原生支持各种连接器。下表列出了所有可用的连接器。

名称	版本	Source	Sink
Filesystem		Bounded and Unbounded Scan	Streaming Sink, Batch Sink