Flink 1.9 Table & SQL 第一个程序 WordCount

Posted 2022-04-12 @SmartSi

Flink 版本：1.9.3

在 Flink 1.9 版本，Table API 和 SQL 功能尚不完整，正在积极开发中。

1. 依赖

1.1 Planner

从 Flink 1.9 开始，Flink 提供了两种不同的 Planner 实现来执行 Table & SQL API 程序：

• Blink Planner：Flink 1.9+
• Old Planner：Flink 1.9 之前

Planner 负责将关系运算符转换为可执行的、优化的 Flink 作业。两个 Planner 都带有不同的优化规则和运行时类。它们在支持的功能集上会有所不同。在生产中，我们还是推荐使用在 Flink 1.9 版本之前就存在的 Old Planner。

1.2 依赖项

根据你使用的编程语言，需要将 Java 或者 Scala API 添加到项目中，以便能使用 Table API 和 SQL 来定义作业流：

<dependency>
  <groupId<