Flink源码解析系列--StreamExecutionEnvironment类

本文的Flink源码版本为: 1.15-SNAPSHOT，读者可自行从Github clone.

Flink 程序看起来像一个转换 DataStream 的常规程序。每个程序由相同的基本部分组成：

• 获取一个执行环境（execution environment）；
• 加载/创建初始数据；
• 指定数据相关的转换；
• 指定计算结果的存储位置；
• 触发程序执行。

StreamExecutionEnvironment 是所有 Flink 程序的基础。

创建

你可以使用 StreamExecutionEnvironment 的如下静态方法获取 StreamExecutionEnvironment：

getExecutionEnvironment();

createLocalEnvironment();

createRemoteEnvironment(String host, int port, String... jarFiles);
1
2
3
4
5

通常，你只需要使用 getExecutionEnvironment() 即可，因为该方法会根据上下文做正确的处理：如果你在 IDE 中执行你的程序或将其作为一般的 Java 程序执行，那么它将创建一个本地环境，该环境将在你的本地机器上执行你的程序。如果你基于程序创建了一个 JAR 文件，并通过命令行运行它，Flink 集群管理器将执行程序的 main 方法，同时 getExecutionEnvironment() 方法会返回一个执行环境以在集群上执行你的程序。