DataStream之间的转换

函数

• flatMap等内置函数
  • reduce
  • fold
  • sum
  • max
  • windAll
• Richfunction 函数实现
• operetors
  • connect 与union 合并流
    • connect之后生成ConnectedStreams 会对两个的数据应用不同的处理方法，并且双流之间可以进行共享状态 (比如计数) 这在第一个流的输入会影响第二个流时 会非常有用。union合并多个流，新的流包含所有流的数据
    • union是DataStream->DataStream
    • connect只能连接两个流，union可以连接多余2个流
    • connecr连接的两个流数据类型可以不一致，而union连接的流的类型必须一致

reduce 与 fold

• 分组之后对分组的数据也就是keyedStream进行各种聚合操作
• KeyedStream->DataStream
• 对于KeyedStream的聚合操作都是滚动的

OuputTab 拆分流