1.分布式流处理的基本模型
逻辑模型：
一个source 一个operation 一个sink
物理模型：
多个source对应多个operation一个sink
不同节点直接的数据传输需要接触到网络
2.流的基本操作
单条流的操作：
map
两条流的操作：
connect：connectedstream，把两条不同数据类型的流合并到一条流中
comap：把这条流又返回给单条流
拆分流的操作：
split：splitstream
原文：https://www.cnblogs.com/javazyh/p/13040063.html