Repository: spark Updated Branches: refs/heads/branch-2.1 ca25b1e51 -> ac7107fe7
[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. (cherry picked from commit 2a5f52a7146abc05bf70e65eb2267cd869ac4789) Signed-off-by: Sean Owen <so...@cloudera.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ac7107fe Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ac7107fe Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ac7107fe Branch: refs/heads/branch-2.1 Commit: ac7107fe70fcd0b584001c10dd624a4d8757109c Parents: ca25b1e 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:54 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/ac7107fe/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
