本文重点
本文将通过一个统计词频的小程序来看一下flink是如何对数据进行批处理的，需要声明的是，一般我们使用Flink常常用于流式处理，即使是有界的数据，我们也将其看成是无界数据进行流式处理，所以批量处理并不是很常用，这里只是为了了解一下Flink是如何进行批处理的。
Flink流程序的基本构成
一个 Flink 程序，其实就是对 DataStream 的各种转换。具体来说，代码基本上都由以下几 部分构成：
⚫ 获取执行环境（execution environment
⚫ 读取数据源（source）
⚫ 定义基于数据的转换操作（transformations）
⚫ 定义计算结果的输出位置（sink）
⚫ 触发程序执行（execute）
其中，获取环境和触发执行，都可以认为是针对执行环境的操作。
)
