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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org