Flink 程序剖析

Flink 程序程序看起来像转换数据集合的普通程序。每个程序都由相同的基本部分组成：

• 获得一个执行环境
• 加载/创建初始数据
• 指定在这些数据上的转换操作
• 指定计算结果存放位置
• 触发程序执行

现在我们将对每一步进行一个简要的概述。请注意，Java DataSet API 的所有核心类都可以在 org.apache.flink.api.java 包中找到，而 Java DataStream API 的类可以在 org.apache.flink.streaming.api 中找到。Scala DataSet API 的所有核心类都可以在 org.apache.flink.api.scala 包中找到，而 Scala DataStream API 的类可以在 org.apache.flink.streaming.api.scala 中找到。

StreamExecutionEnvironment 是所有 Flink 程序的基础。你可以使用 StreamExecutionEnvironment 上的如下静态方法获取：
Java版本:

getExecutionEnvironment()
createLocalEnvironment(