From 2a5f52a7146abc05bf70e65eb2267cd869ac4789 Mon Sep 17 00:00:00 2001 From: Carson Wang Date: Wed, 28 Dec 2016 12:12:44 +0000 Subject: [PATCH] [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 Closes #16419 from carsonwang/FixDoc. --- .../src/main/scala/org/apache/spark/sql/ForeachWriter.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 b94ad59fa2..372ec262f5 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() { + * datasetOfString.writeStream().foreach(new ForeachWriter() { * * @Override * public boolean open(long partitionId, long version) {