HyukjinKwon commented on a change in pull request #30346:
URL: https://github.com/apache/spark/pull/30346#discussion_r522714463
##########
File path: python/pyspark/streaming/context.py
##########
@@ -286,11 +321,18 @@ def queueStream(self, rdds, oneAtATime=True,
default=None):
Create an input stream from a queue of RDDs or list. In each batch,
it will process either one or all of the RDDs returned by the queue.
- .. note:: Changes to the queue after the stream is created will not be
recognized.
-
- :param rdds: Queue of RDDs
- :param oneAtATime: pick one rdd each time or pick all of them once.
- :param default: The default rdd if no more in rdds
+ Parameters
+ ----------
+ rdds : :class:`RDD`, list
+ Queue of RDDs
+ oneAtATime : int, optional
Review comment:
```suggestion
oneAtATime : bool, 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]
