Github user HyukjinKwon commented on a diff in the pull request: https://github.com/apache/spark/pull/21571#discussion_r196626934 --- Diff: python/pyspark/sql/tests.py --- @@ -2126,6 +2126,42 @@ class WriterWithNonCallableClose(WithProcess): tester.assert_invalid_writer(WriterWithNonCallableClose(), "'close' in provided object is not callable") + def test_streaming_foreachBatch(self): + q = None + collected = dict() + + def collectBatch(batch_df, batch_id): --- End diff -- collectBatch -> collect_batch per PEP 8.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org