1.Flink源码算子

Flink源码算子

       Flink应用程序的源码核心组件包括源(source)、转换(transformation)和目的源码地(sink)，它们共同构成有向图，源码数据流从源开始，源码大龙摆尾源码流向sink结束。源码源算子如env.addSource的源码高端楼梯源码底层实现涉及监控函数和连续读取文件操作，如env.readTextFile()调用了一系列方法，源码最终通过add.source添加到流处理环境。源码

       转换算子种类繁多，源码如map和sum。源码map算子通过函数转换，源码经过层层调用，源码最终调用transformations.add方法，源码货车物流源码将算子添加到作业的源码血缘依赖列表中。print算子作为sink，源码通过addSink操作生成StreamSink operator，fresco源码介绍其SinkFunction负责数据处理，如PrintSinkFunction的打印操作。

       构建过程中，新闻源码jsp每次转换都会产生新的数据流，这些StreamTransformation会以隐式链表或图的形式组织起来，input属性记录上下游关系。执行阶段，会生成StreamGraph和JobGraph，然后提交到集群进行调度。