概念
Flink 中的 DataStream 程序是对数据流进行转换（例如过滤、更新状态、定义窗口、聚合）的常规程序。数据流最初是从各种来源（例如，消息队列、套接字流、文件）创建的。结果通过接收器返回，例如可以将数据写入文件或标准输出（例如命令行终端）。Flink 程序可以在各种上下文中运行，可以独立运行，也可以嵌入到其他程序中。执行可以在本地 JVM 中发生，也可以在许多机器的集群上发生。
DataStream API 既可以处理无解流数据, 也可以处理有界的批量数据. 意思是既支持流处理,也支持离线的批处理.
一. 构建flink程序的一般步骤
1.获得一个execution environment
2.加载/创建初始数据，
3.指定对此数据的转换
4.指定将计算结果放在哪里，
5.触发程序执行
