Flink Connectors

Posted 2022-06-18 宝哥大数据

文章目录

• 一、DataStream Connectors
• • 1.1、Souce --- [flink-1.10](https://chbxw.blog.csdn.net/article/details/106487880#t3)
  • • 1.1.1、文件/HDFS，集合的源，Kafka Source，自定义Source
  • 1.2、Sink -- [flink-1.10](https://chbxw.blog.csdn.net/article/details/106487880#t12)
  • • 1.2.1、HDFS Sink， Redis Sink
    • 1.2.2、自定义Sink（JDBC Sink）
• 二、Table & SQL Connectors

一、DataStream Connectors

注意： DataStream中的Connector就是 Source 和 Sink。

1.1、Souce — flink-1.10

1.1.1、文件/HDFS，集合的源，Kafka Source，自定义Source

• Flink 1.11之后的新版数据源

1.2、Sink – flink-1.10

1.2.1、HDFS Sink， Redis Sink

1.2.2、自定义Sink（JDBC Sink）

• Flink-1.11开始提供了JDBC Sink

二、Table & SQL Connectors