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: [email protected]
For additional commands, e-mail: [email protected]
