知识卡片

程序骨架五步

专业/工作 · 502.i

内容

DataStream 程序通常按执行环境、Source、Transformation、Sink、execute 五步组织。前四步只是构建图,execute 才触发提交运行。发散:Flink 代码像声明一条生产线,最后一步才真正开机。

参考来源

- 位置:《Flink原理与实践》第4章《DataStream API的介绍和使用》(源文件:_epub-src/OEBPS/Text/chapter07.xhtml) - 结论依据:原文围绕“当程序明确调用execute()方法时”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。 - 原始内容:Flink是延迟执行(Lazy Evaluation)的,即当程序明确调用execute()方法时,Flink才会将数据流图转化为一个JobGraph,提交给JobManager,JobManager根据当前的执行环境来执行这个作业。