SparkStreaming自定义数据源实现wordcount案例_2.自定义数据采集器 需要继承receiver,并实现onstart、onstop方法来自定义数据源-CSDN博客网友收藏

SparkStreaming自定义数据源实现wordcount案例_2.自定义数据集器 需要继承receiver,并实现onstart、onstop方法来自定义数据源-CSDN博客

文章浏览阅读97次。项目需求:需求:自定义数据源,实现监控某个端口号,获取该端口号内容。需要继承Receiver,并实现onStart、onStop方法来自定义数据源采集。代码实现: def main(args: Array[String]): Unit = { //创建配置对象文件 ......
阅读全文