Flink DataStream API 编程指南
（对于Flink的开发，建议使用Java，Scala的支持未来会被移除）
DataStream是什么
DataStream API得名于DataStream这个Java类，可以将它们视为可以包含重复项的不可变数据集合。该数据可以是有限的，也可以是无限的，用于处理它们的API是相同的。
DataStream在用法上和普通的Java集合类似，但在一些关键方面有很大的不同。它们是不可变的，这意味着一旦创建了它们，就不能添加或删除元素。你可以在上面执行各种transformations操作。
通过在Flink程序中添加数据源，可以创建初始的DataStream。然后你可以由此派生出新的流，并使用map、filter等API方法将它们组合起来。
剖析Flink程序整体过程
Flink程序就是对DataStream的各种转换（transformations）的过程，每个程序由相同的基本部分组成：
- 获取执行环境
- 加载/创建初始数据
- 指定此数据的转换
- 指定将计算结果的存放位置
- 触发程序执行
下面以java api的方式来说明以上过程：
1）获取执行环境
可以通过 StreamExecutionEnvironment 的方法来获得：