一、StreamOperator的定义与实现紧接上文，Transformation负责描述DataStream之间的转换操作，Transformation结构中最主要的组成部分就是StreamOperator1.1StreamOperator接口关系图由关系图不难看出：不管是OneInputStreamOperator还是TwoInputStreamOperator类型的算子都继承自AbstractStreamOperator基本实现类。在调度和执行task实例是，会通过AbstractStreamOperator提供的入口方法触发和执行Operator,同时AbstractStreamOpe