sparkstream.textfilstreaming(localpathdirectory)。我得到空结果

我给了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()))
hezhen2009 回答:sparkstream.textfilstreaming(localpathdirectory)。我得到空结果

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3152248.html

大家都在问