老师，为什么,监控Windows本地下的目录，复制文件过去，无统计结果，也不报错

来源：7-7 -案例实战之Spark Streaming处理文件系统数据

人唯优2018

2018-08-20

val lines = ssc.textFileStream("file:///E:/idea_workspace/spark_stream/datas/")

val result = lines.flatMap(_.split(" ")).map((_,1)).reduceByKey(_ + _)
result.print()

ssc.start()
ssc.awaitTermination()

写回答

2回答

Michael_PK

2018-08-20

已采纳

仔细听这个视频，为什么没数据我讲解过

Michael_PK

慕侠0147551

看提醒应该就是缺失jar，找到问题就好

2018-11-28

共8条回复

慕粉0909169327

2018-09-07

感觉要新写一个文件，将文件复制进文件夹才可以，已有的文件复制没成功O(∩_∩)O

Michael_PK

对的，要文件时间比启动时间晚才行

2018-09-07

共1条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程

相似问题

怎么量化flume + kafka带来的性能提升

回答 1

无法监控到data.log日志

回答 1

我在执行本地文件时报这个错

回答 1

window 系统不能写入hbase 到这步以后就卡住了,不再执行

回答 4

sparkStreaming处理本地文件数据

回答 1

打开慕课网App查看更多内容