From d15ab4b4833487d1c3f87f4461fafc2f9a13cd49 Mon Sep 17 00:00:00 2001 From: Onwuka Gideon Date: Fri, 3 Aug 2018 22:28:28 +0100 Subject: [PATCH] Changed "an" to "a" --- python/pyspark/streaming/context.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py index 445ac8f75fb0d..3fa57ca85b37b 100644 --- a/python/pyspark/streaming/context.py +++ b/python/pyspark/streaming/context.py @@ -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.