Skip to content
Snippets Groups Projects
Unverified Commit ac7107fe authored by Carson Wang's avatar Carson Wang Committed by Sean Owen
Browse files

[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.

(cherry picked from commit 2a5f52a7)
Signed-off-by: default avatarSean Owen <sowen@cloudera.com>
parent ca25b1e5
No related branches found
No related tags found
No related merge requests found
......@@ -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) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment