49分钟
细说Flink之scala数据流
本课程我们将开始 Date stream 的相关学习,和学员一起共同完成Scala代码下的source、算子操作、partition、sink 4个模块学习目标。 本门课程我们会重点关注技术细节,比如…
本课程我们将开始 Date stream 的相关学习,和学员一起共同完成Scala代码下的source、算子操作、partition、sink 4个模块学习目标。
本门课程我们会重点关注技术细节,比如:Sink是程序的数据输出,在实际操作中,我们如何通过Stream来为程序添加一个Sink? 又如何通过 Redis 来实现 Sink 存储数据基本操作?
在完成本门课程学习后,学员将会对 Scala 语言下的算子操作、partition、sink有进一步认识,为后续学习奠定更好基础。
1.DataStreamAPI之source-(scala代码)
2.DataStreamAPI之transformation-(scala代码)
3.DataStreamAPI之partition-(scala代码)
4.DataStreamAPI之sink-(scala代码)
课程素材
测试
徐葳
大数据专家