diff options
| author | Carson Wang <carson.wang@intel.com> | 2016-12-28 12:12:44 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-12-28 12:12:44 +0000 |
| commit | 2a5f52a7146abc05bf70e65eb2267cd869ac4789 (patch) | |
| tree | fef6f8cb57e1c6ceb84cfb85f97692aa2de238c7 /sql/core/src/main | |
| parent | 76e9bd74885a99462ed0957aad37cbead7f14de2 (diff) | |
| download | spark-2a5f52a7146abc05bf70e65eb2267cd869ac4789.tar.gz spark-2a5f52a7146abc05bf70e65eb2267cd869ac4789.tar.bz2 spark-2a5f52a7146abc05bf70e65eb2267cd869ac4789.zip | |
[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.wang@intel.com>
Closes #16419 from carsonwang/FixDoc.
Diffstat (limited to 'sql/core/src/main')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala | 4 |
1 files 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<String>() { + * datasetOfString.writeStream().foreach(new ForeachWriter<String>() { * * @Override * public boolean open(long partitionId, long version) { |