FlinkFlink SQL 读取 CSV 文件

Posted 2021-11-02 九师兄

文章目录

• • 3.7 source
  • 3.7 连续查询
  • 3.8 Sink Tables
  • • 3.8.1 案例1

3.7 source

与所有SQL引擎一样，Flink SQL 对表进行查询操作。但与传统数据库不同，Flink不管理本地静态数据；相反，它在外部表上进行持续查询操作。

Flink数据处理pipeline从源表开始。源表产生在查询执行期间需要操作的数据行；它们是FROM子句中引用的表。这些表可以是Kafka主题、数据库、文件系统，或者Flink知道如何读取的任何其他系统。

表可以通过SQL客户端或使用环境配置文件定义。SQL客户端支持类似于传统SQL的SQL DDL命令。标准SQL DDL用于创建、修改、删除表。

Flink支持可用于表的不同连接器和格式。下面的示例定义了一个源表，该源表读取CSV文件，其中在CREATE表语句中将emp_id、name、dept_id作为列。