This is an automated email from the ASF dual-hosted git repository.
srowen 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 0ea91da [MINOR][DOCS] ForeachBatch java example fix
0ea91da is described below
commit 0ea91dab2ed2808edaf42398eda0614df26358d1
Author: roland-ondeviceresearch <[email protected]>
AuthorDate: Tue Mar 3 09:24:33 2020 -0600
[MINOR][DOCS] ForeachBatch java example fix
### What changes were proposed in this pull request?
ForEachBatch Java example was incorrect
### Why are the changes needed?
Example did not compile
### Does this PR introduce any user-facing change?
Yes, to docs.
### How was this patch tested?
In IDE.
Closes #27740 from roland1982/foreachwriter_java_example_fix.
Authored-by: roland-ondeviceresearch <[email protected]>
Signed-off-by: Sean Owen <[email protected]>
(cherry picked from commit a4aaee01fa8e71d51f49b24889d862422e0727c7)
Signed-off-by: Sean Owen <[email protected]>
---
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 515ba07..dce4b35 100644
--- a/docs/structured-streaming-programming-guide.md
+++ b/docs/structured-streaming-programming-guide.md
@@ -2059,7 +2059,7 @@ streamingDF.writeStream.foreachBatch { (batchDF:
DataFrame, batchId: Long) =>
{% highlight java %}
streamingDatasetOfString.writeStream().foreachBatch(
- new VoidFunction2<Dataset<String>, Long> {
+ new VoidFunction2<Dataset<String>, Long>() {
public void call(Dataset<String> dataset, Long batchId) {
// Transform and write batchDF
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
