Flink程序开发步骤

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

上一篇:关于webRTC的SDP格式(RTCConfiguration中的sdp_semantics)


下一篇:Oracle 执行计划(Explain Plan)