编程语言
首页 > 编程语言> > Flink程序开发步骤

Flink程序开发步骤

作者:互联网

开发Flink程序有固定的流程。
(1)获得一个执行环境。
(2)加载/创建初始化数据。
(3)指定操作数据的Transaction算子。
(4)指定计算好的数据的存放位置。
(5)调用execute()触发执行程序。
注意:Flink程序是延迟计算的,只有最后调用execute()方法的时候才会真正触发执行程序。
延迟计算的好处:你可以开发复杂的程序,Flink会将这个复杂的程序转成一个Plan,并将Plan作为一个整体单元执行!

标签:execute,程序开发,步骤,Flink,程序,执行程序,Plan,延迟
来源: https://blog.csdn.net/chenshijie2011/article/details/114068706