This is an automated email from the ASF dual-hosted git repository.
srowen pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new e332198 [MINOR][DOCS] ForeachBatch java example fix
e332198 is described below
commit e332198f5aab2eec30dedfab66296382d31d3245
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 47d8994..1776d23 100644
--- a/docs/structured-streaming-programming-guide.md
+++ b/docs/structured-streaming-programming-guide.md
@@ -2105,7 +2105,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]
