Stream的计算模型采用的是PUSH模式，上游主动向下游推送数据，上下游之间采用生产者-消费者模式，下游收到数据触发计算，没有数据则进入等待状态。PUSH模式的数据处理过程也叫作Pipeline，提到Pipeline或者流水线的时候，一般是指PUSH模式的数据处理过程。
RecordWriter是负责将Task的数据输出给下游Task。
StreamOperator
我们开发的Flink程序，最终会转换成一个一个的StreamOperator。
其抽象子类AbstractStreamOperator提供了生命周期和属性、方法等的默认实现。
任意一个算子必须继承