我们可以使用sparksql新的Dataframe保存api来实现这一点，该api允许附加到现有的输出。默认情况下，saveastextfile无法保存到包含现有数据的目录（请参阅https://spark.apache.org/docs/latest/sql-programming-guide.html#save-模式）。https://spark.apache.org/docs/latest/streaming-programming-guide.html#dataframe-sql操作包括如何设置sparksql上下文以用于sparkstreaming。
假设使用sqlcontextsingleton从指南中复制该部分，则生成的代码如下所示：

data.foreachRDD{rdd =>
  val sqlContext = SQLContextSingleton.getInstance(rdd.sparkContext)
  // Convert your data to a DataFrame, depends on the structure of your data
  val df = ....
  df.save("org.apache.spark.sql.json", SaveMode.Append, Map("path" -> path.toString))
}

（注意上面的示例使用json保存结果，但是您也可以使用不同的输出格式）。