0


大数据Flink进阶(七):Flink批和流案例总结

Flink批和流案例总结

关于Flink 批数据处理和流式数据处理案例有以下几个点需要注意:

一、Flink程序编写流程总结

编写Flink代码要符合一定的流程,Flink代码编写流程如下:

a. 获取flink的执行环境,批和流不同,Execution Environment。

b. 加载数据数据-- soure。

c. 对加载的数据进行转换-- transformation。

d. 对结果进行保存或者打印-- sink。

e. 触发flink程序的执行 --env.execute()

在Fli


本文转载自: https://blog.csdn.net/xiaoweite1/article/details/129568315
版权归原作者 Lansonli 所有, 如有侵权,请联系我们删除。

“大数据Flink进阶(七):Flink批和流案例总结”的评论:

还没有评论