开发Flink程序有固定的流程。
(1)获得一个执行环境。
(2)加载/创建初始化数据。
(3)指定操作数据的Transaction算子。
(4)指定计算好的数据的存放位置。
(5)调用execute()触发执行程序。
注意:Flink程序是延迟计算的,只有最后调用execute()方法的时候才会真正触发执行程序。
延迟计算的好处:你可以开发复杂的程序,Flink会将这个复杂的程序转成一个Plan,并将Plan作为一个整体单元执行!
相关文章
- 01-04iphone – 在Windows 7上开发iOS应用程序
- 01-04微信小程序开发之搞懂flex布局1——Flexbox
- 01-04程序开发心理学阅读笔记——第II篇
- 01-04开发winform程序的酱香老酒dockpanel
- 01-04程序开发心理学阅读笔记——第I篇
- 01-04SpringBoot 在线协同办公小程序开发 全栈式项目实战
- 01-04【程序人生】那些开发工具的默认端口
- 01-04微信小程序开发——消除Now you can provide attr `wx:key` for a `wx:for` to improve performance.
- 01-04软件开发程序猿日常必备,现用现查&日志记录
- 01-04在运行程序时报错:"如果在 Code First 模式下使用,则使用 T4 模板为 Database First 和 Model First 开发生成的代码可能无法 正常运行。若要继续使用 Database First 或 Model First,请确保在执行应用程序的 config 文件中指 定 Entity Framework 连接字符串。若要将这些从 Database First 或 Mod