Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21571#discussion_r195597031
--- Diff: python/pyspark/sql/streaming.py ---
@@ -854,6 +856,20 @@ def trigger(self, processingTime=None, once=None,
continuous=None):
self._jwrite = self._jwrite.trigger(jTrigger)
return self
+ def foreachBatch(self, func):
--- End diff --
add docs
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
