Flink 1.14 Table & SQL 第一个程序 WordCount

Posted 2022-05-31 @SmartSi

Flink 版本：1.14.4

Apache Flink 具有两个关系 API：Table API 和 SQL。Table API 是用于 Java、Scala 和 Python 的集成语言查询 API，可以以非常直观的方式组合不同关系运算符（例如 SELECT、FILTER 以及 JOIN）构建复杂查询。Flink SQL 基于 Apache Calcite 实现。无论输入是无界的（流式）还是有界的（批处理），任意查询都具有相同的语义并输出相同的结果。Table API 和 SQL 可以与 Flink 的 DataStream API 无缝集成。

1. 依赖

1.1 Planner

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

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

在 1.14 新版本中，Old Planner 被移除，Blink Planner 将成为 Planner 的唯一实现。

1.2 依赖项

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

<