StreamGraph 代表最原始的 topology，没有 chain 优化， 没有并行度概念，只有 StreamNode和StreamEdge。
StreamGraph 会合并一些虚拟节点，列如SelectNodes，SideOutputNodes，PartitionNodes，这些节点不会生成StreamNode。
StreamGraph 由 org.apache.flink.streaming.api.graph.StreamGraphGenerator#generate 生成。
StreamGraph 的生成过程就是遍历已经生成的 transformations，对每个transformation调用 transform 方法。
每个transformation 如果不是虚拟节点，那么就会通过 StreamGraph.addOperator 方法生成 StreamNode，并添加到streamNodes集合里面去。
然后添加StreamEdge，虚拟节点包含在StreamEdge里面
概述 StreamGraph 代表最原始的topology，没有 chain 优化， 没有并行度概念，只有 Str...
StreamGraph是什么？ StreamGraph顾名思义是流图，它描述的是一个数据流的拓补结构，包含了创建J...
StreamExecutionEnvironment StreamExecutionEnvironment 是 F...
例子 如SocketWindowWordCount例子为例，分析Graph的构建过程； 如代码，整个算子链执行流程...
Flink 中的执行图可以分成四层：StreamGraph -> JobGraph -> ExecutionGra...
Flink根据算子之间的依赖关系构建出Transformations并依次形成StreamGraph、JobGra...
一、Flink Graph（DAG） 在Flink中的执行图可以分成四层：StreamGraph -> JobGr...
背景 之前我们知道了Flink 是如何生成 StreamGraph[https://blog.csdn.net/j...
在执行Flink任务的时候，会涉及到三个Graph，分别是StreamGraph，JobGraph，Executi...
在执行Flink任务的时候，会涉及到三个Graph，分别是StreamGraph，JobGraph，Executi...
本文标题：StreamGraph
本文链接：https://www.haomeiwen.com/subject/ybdsjqtx.html
网友评论