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