HyukjinKwon commented on a change in pull request #30346:
URL: https://github.com/apache/spark/pull/30346#discussion_r522720697
##########
File path: python/pyspark/streaming/dstream.py
##########
@@ -423,11 +432,15 @@ def window(self, windowDuration, slideDuration=None):
Return a new DStream in which each RDD contains all the elements in
seen in a
sliding window of time over this DStream.
- :param windowDuration: width of the window; must be a multiple of this
DStream's
- batching interval
- :param slideDuration: sliding interval of the window (i.e., the
interval after which
- the new DStream will generate RDDs); must be a
multiple of this
- DStream's batching interval
+ Parameters
+ ----------
+ windowDuration : int
+ width of the window; must be a multiple of this DStream's
+ batching interval
+ slideDuration : int
Review comment:
```suggestion
slideDuration : int, optional
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
