Flink程序关键一步：触发环境执行

本文重点

在前面的课程中，我们学习了很多的flink流程序，在这些流程序中都有一个共同的特点，就是在代码的最后一行都有一个env.execute();，它的作用是什么呢？

触发环境执行

我们前面学习了源算子，转换算子，聚合算子，输出sink算子等等都是对流数据的操作，即使是写完输出（sink）操作并不代表程序已经结束，只不过是在定义数据流图。

此时数据还没有开始流动，只有调用execute()方法，数据才会开始流动，才会真正的触发各个算子的计算，这也被称为“延迟执行”或“懒执行”。execute()方法将一 直等待作业完成，然后返回一个执行结果（JobExecutionResult）。