Flink批和流案例总结
关于Flink 批数据处理和流式数据处理案例有以下几个点需要注意:
一、Flink程序编写流程总结
编写Flink代码要符合一定的流程,Flink代码编写流程如下:
a. 获取flink的执行环境,批和流不同,Execution Environment。
b. 加载数据数据-- soure。
c. 对加载的数据进行转换-- transformation。
d. 对结果进行保存或者打印-- sink。
e. 触发flink程序的执行 --env.execute()
在Fli
版权归原作者 Lansonli 所有, 如有侵权,请联系我们删除。