-
- 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作为列。
