DataStream API（源算子 Sources，转换算子 Transformation，输出算子 Sink）

执行环境：StreamExecutionEnvironment

源算子 Source：
readTextFile,readFile,socketTextStream,fromCollection,fromElements,generateSequence

转换算子 Transformation：
基本转换算子：
map 一对一转换
flatMap 一行变零到多行
filter 过滤

聚合算子 Aggregation：
sum 累加
min 最小
max 最大
minBy
maxBy
reduce 归约聚合
keyBy 按键分区
fold 滚动折叠

窗口算子：
Window
WindowAll
Window Apply
WindowReduce
union
Window Join
Interval Join
Window CoGroup
connect
CoMap, CoFlatMap
Iterate

split
select