Flink DAG编译和优化

Flink DAG编译和优化 1. 建立ProgramPlan。 class ExecutionEnvironment: public Plan createProgramPlan(); Plan描述了全部的数据源,全部Sink,全部操做,能够在PlanExecutor中做为独立单元执行。java 2. 编译。 class Optimizer: private OptimizerPostPass
相关文章
相关标签/搜索