Apache Flink Client生成StreamGraph

概述 上文咱們分析提交流程時，RemoteStreamEnvironment類的execute方法的第一步就是生成StreamGraph。php StreamGraph是用於表示流的拓撲結構的數據結構，它包含了生成JobGraph的必要信息。它的類繼承關係圖以下：node 若是你按照StreamGraph的繼承鏈向上追溯，最終會發現它實現了接口FlinkPlan。Flink在這裏效仿的是數據庫的執

>>阅读原文<<