Apache Flink Client生成StreamGraph

概述 上文咱们分析提交流程时,RemoteStreamEnvironment类的execute方法的第一步就是生成StreamGraph。php StreamGraph是用于表示流的拓扑结构的数据结构,它包含了生成JobGraph的必要信息。它的类继承关系图以下:node 若是你按照StreamGraph的继承链向上追溯,最终会发现它实现了接口FlinkPlan。Flink在这里效仿的是数据库的执
相关文章
相关标签/搜索