diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py index 78828ea4ea3c2..bbb4f6764e266 100644 --- a/python/pyspark/streaming/context.py +++ b/python/pyspark/streaming/context.py @@ -94,6 +94,9 @@ def clean_up_handler(*args): @property def sparkContext(self): + """ + Return SparkContext which is associated this StreamingContext + """ return self._sc def start(self):