我给了Spark文本文件流式传输的本地路径。但是,即使添加了新文件,它也会给出空结果。该路径存在,并且也没有打开。你能告诉我如何纠正这个问题吗?
val pathFile:Path=new Path(
"file:\\\\\\D:\\sparklearning\\inputFileStreaming\\"
)
println(pathFile.toString())
val linesDStream = streamingContext.textFileStream(pathFile.toString)
linesDStream.foreachRDD(x=>println(x.toString()))