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 <rol...@ondeviceresearch.com> 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 <rol...@ondeviceresearch.com> Signed-off-by: Sean Owen <sro...@gmail.com> (cherry picked from commit a4aaee01fa8e71d51f49b24889d862422e0727c7) Signed-off-by: Sean Owen <sro...@gmail.com> --- 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: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org