Hello,
How should I write a text file stream DStream to HDFS.
I tried the the following
 val lines = ssc.textFileStream("hdfs:/user/hadoop/spark/streaming/input/")
    lines.saveAsTextFile("hdfs:/user/hadoop/output1")

 val lines = ssc.textFileStream("hdfs:/user/hadoop/spark/streaming/input/")
    lines.saveAsHadoopFiles("hdfs:/user/hadoop/output1","out")

in both cases i received compile errors saying:
 is not a member of org.apache.spark.streaming.dstream.DStream[String]

Thanks in advance for help.

Reply via email to