Structure Stream訪問(wèn)方式

code examples

import org.apache.spark.sql.streaming._
val df = spark.readStream.text("/home/testhdfs")
val ps = df.writeStream.format("console").outputMode(OutputMode.Append).start

結(jié)論

basedir = /home/testhdfs
支持：mv file to basedir（/home/testhdfs）
不支持：mv directory to basedir

如果往basedir里面添加文件夾會(huì)出現(xiàn)ERROR:

java.lang.AssertionError: assertion failed: Conflicting directory structures detected. Suspicious paths:
        hdfs://172.17.1.180:9000/home/testhdfs/data1
        hdfs://172.17.1.180:9000/home/testhdfs
If provided paths are partition directories, please set "basePath" in the options of the data source to specify the root directory of the table. If there are multiple root directories, please load them separately and then union them.

spark streaming 訪問(wèn)方式

測(cè)試textFile接口使用

import org.apache.spark.streaming._
val ssc = StreamingContext.getActiveOrCreate(() => new StreamingContext(sc,                  Seconds(120)))
val ds1 = ssc.textFileStream("/home/testhdfs2")
ds1.print
ssc.start

結(jié)論

支持：mv file to basedir（/home/testhdfs2）
支持：mv directory to basedir