总览图
StreamGraph
类:StreamGraph
生成器类:StreamGraphGenerator
节点类:StreamNode
边类:StreamEdge
执行StreamExecutionEnviroment.execute()之后会调用:StreamGraphGenerator.generate()
不是所有Transfomation都转化成StreamNode,对流逻辑切分的不会转化比如Union。Map、Filter这种有计算逻辑的会转化成StreamNode。
JobGraph
JobVertex
JobEdge
IntermediateDataSet
主要就是Chain
ExecutionGraph
ExecutionJobVertex构造函数会生成一个IntermediateResult
ExecutionVertex构造函数中会生成一个IntermediateResultPartition