我是 Spark/Scala 的新手。我知道如何加载 CSV 文件:
sqlContext.read.format("csv")
Run Code Online (Sandbox Code Playgroud)
以及如何读取文本流和文件流:
scc.textFileStream("""file:///c:\path\filename""");
scc.fileStream[LongWritable, Text, TextInputFormat](...)
Run Code Online (Sandbox Code Playgroud)
但是如何读取CSV格式的文本流?谢谢,列维