Skip to content

Commit

Permalink
Changed "an" to "a"
Browse files Browse the repository at this point in the history
  • Loading branch information
dongido001 authored Aug 3, 2018
1 parent df8c492 commit d15ab4b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python/pyspark/streaming/context.py
Original file line number Diff line number Diff line change
Expand Up @@ -287,7 +287,7 @@ def _check_serializers(self, rdds):

def queueStream(self, rdds, oneAtATime=True, default=None):
"""
Create an input stream from an queue of RDDs or list. In each batch,
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.
Expand Down

0 comments on commit d15ab4b

Please sign in to comment.