socketTextStream flumeStream kafkaStream fileStream networkStream
fileStream:监控一个HDFS目录,有新文件进入这个目录,获取这个文件的文件名,创建一个DStream即可。
socketTextStream flumeStream kafkaStream fileStream networkStream
fileStream:监控一个HDFS目录,有新文件进入这个目录,获取这个文件的文件名,创建一个DStream即可。
本文标题:spark streaming支持的输入源有哪些
本文链接:https://www.haomeiwen.com/subject/wprnmctx.html
网友评论