You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2020/02/22 00:55:22 UTC
[spark] branch branch-2.4 updated: [MINOR][DOCS] Fix ForEachWriter
Java example
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 8fdd039 [MINOR][DOCS] Fix ForEachWriter Java example
8fdd039 is described below
commit 8fdd039c3d648d2a557ed5bc438290725d85cf64
Author: roland-ondeviceresearch <ro...@ondeviceresearch.com>
AuthorDate: Sat Feb 22 09:52:45 2020 +0900
[MINOR][DOCS] Fix ForEachWriter Java example
### What changes were proposed in this pull request?
Structured streaming documentation example fix
### Why are the changes needed?
Currently the java example uses incorrect syntax
### Does this PR introduce any user-facing change?
Yes
### How was this patch tested?
In IDE
Closes #27671 from roland1982/foreachwriter_java_example_fix.
Authored-by: roland-ondeviceresearch <ro...@ondeviceresearch.com>
Signed-off-by: HyukjinKwon <gu...@apache.org>
---
docs/structured-streaming-programming-guide.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md
index 3f77f89..515ba07 100644
--- a/docs/structured-streaming-programming-guide.md
+++ b/docs/structured-streaming-programming-guide.md
@@ -2156,7 +2156,7 @@ streamingDatasetOfString.writeStream.foreach(
In Java, you have to extend the class `ForeachWriter` ([docs](api/java/org/apache/spark/sql/ForeachWriter.html)).
{% highlight java %}
streamingDatasetOfString.writeStream().foreach(
- new ForeachWriter[String] {
+ new ForeachWriter<String>() {
@Override public boolean open(long partitionId, long version) {
// Open connection
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org