1.25学习总结:RDD队列流

一、学习视频

https://www.bilibili.com/video/BV1oE411s7h7?p=58&spm_id_from=pageDriver

二、编程目的

每隔一秒生成一个RDD,将其加入到RDD队列流中,每隔两秒进行处理

三、创建RDD队列流的方法

可以使用streamingConext.queueStream(queueOfRDD)方法来创建基于RDD队列的DStream

四、编程实现

原文地址:https://www.cnblogs.com/wangzhaojun1670/p/14389178.html