Repository: spark Updated Branches: refs/heads/master 76e9bd748 -> 2a5f52a71
[MINOR][DOC] Fix doc of ForeachWriter to use writeStream ## What changes were proposed in this pull request? Fix the document of `ForeachWriter` to use `writeStream` instead of `write` for a streaming dataset. ## How was this patch tested? Docs only. Author: Carson Wang <carson.w...@intel.com> Closes #16419 from carsonwang/FixDoc. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2a5f52a7 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2a5f52a7 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2a5f52a7 Branch: refs/heads/master Commit: 2a5f52a7146abc05bf70e65eb2267cd869ac4789 Parents: 76e9bd7 Author: Carson Wang <carson.w...@intel.com> Authored: Wed Dec 28 12:12:44 2016 +0000 Committer: Sean Owen <so...@cloudera.com> Committed: Wed Dec 28 12:12:44 2016 +0000 ---------------------------------------------------------------------- sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/2a5f52a7/sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala ---------------------------------------------------------------------- diff --git a/sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala b/sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala index b94ad59..372ec26 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala @@ -28,7 +28,7 @@ import org.apache.spark.annotation.{Experimental, InterfaceStability} * * Scala example: * {{{ - * datasetOfString.write.foreach(new ForeachWriter[String] { + * datasetOfString.writeStream.foreach(new ForeachWriter[String] { * * def open(partitionId: Long, version: Long): Boolean = { * // open connection @@ -46,7 +46,7 @@ import org.apache.spark.annotation.{Experimental, InterfaceStability} * * Java example: * {{{ - * datasetOfString.write().foreach(new ForeachWriter<String>() { + * datasetOfString.writeStream().foreach(new ForeachWriter<String>() { * * @Override * public boolean open(long partitionId, long version) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org