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