总览图

image.png

StreamGraph

类:StreamGraph
生成器类:StreamGraphGenerator
节点类:StreamNode
边类:StreamEdge
执行StreamExecutionEnviroment.execute()之后会调用:StreamGraphGenerator.generate()
image.png
不是所有Transfomation都转化成StreamNode,对流逻辑切分的不会转化比如Union。Map、Filter这种有计算逻辑的会转化成StreamNode。

JobGraph

image.png
JobVertex
JobEdge
IntermediateDataSet
主要就是Chain

ExecutionGraph

ExecutionJobVertex构造函数会生成一个IntermediateResult

ExecutionVertex构造函数中会生成一个IntermediateResultPartition