ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[MINOR][DOC] Fix doc of ForeachWriter to use writeStream

Browse source 
## 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.
This commit is contained in:
Carson Wang 2016-12-28 12:12:44 +00:00 committed by Sean Owen
parent 76e9bd7488
commit 2a5f52a714
No known key found for this signature in database
GPG key ID: BEB3956D6717BDDC
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala
View file

@ -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) {