化妆品网站设计欣赏,中学加强校园网站建设,做网站工资,汕头网站排名优化（对于Flink的开发，建议使用Java，Scala的支持未来会被移除）
DataStream是什么
DataStream API得名于DataStream这个Java类，可以将它们视为可以包含重复项的不可变数据集合。该数据可以是有限的，也可以是无限的，用于处理它们的API是相同的。
DataStream在用法上和普通的…（对于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 的方法来获得：
