首页 笔记 图片 查字 
所属分类:Flink
浏览:76
内容:

编程模型:
算子(SourceOperator,TransformationOperator,SinkOperator) /
流 Stream(SourceOperator->TransformationOperator->SinkOperator) /
任务(子任务)/

算子Operator:分类:SourceOperator、TransformationOperator、SinkOperator。
流Stream:SourceOperator开始 -> TransformationOperator转换 -> SinkOperator结束。
任务 Task:Task是Operator经过优化后(算子链合并)的顶点。Task相当于一个进程,由多个SubTask组成,个数有任务/算子并行度决定。
子任务 SubTask:相当于Task中的一个线程,是Task的真实运行实例。

Operator是编程视图中的有向图顶点。
Task是逻辑运行视图中的有向图顶点。
SubTask是物理运行视图中的有向顶点。