Flink DAG編譯和優化

Flink DAG編譯和優化 1. 建立ProgramPlan。 class ExecutionEnvironment: public Plan createProgramPlan(); Plan描述了全部的數據源,全部Sink,全部操做,能夠在PlanExecutor中做爲獨立單元執行。java 2. 編譯。 class Optimizer: private OptimizerPostPass
相關文章
相關標籤/搜索