Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20309#discussion_r162413038
--- Diff: python/pyspark/sql/streaming.py ---
@@ -802,23 +802,38 @@ def trigger(self, processingTime=None, once=None):
>>> writer = sdf.writeStream.trigger(processingTime='5 seconds')
>>> # trigger the query for just once batch of data
>>> writer = sdf.writeStream.trigger(once=True)
+ >>> # trigger the query for execution every 5 seconds
--- End diff --
nit: not quite the right comment
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
