diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py index a1a9be1eae439..78828ea4ea3c2 100644 --- a/python/pyspark/streaming/context.py +++ b/python/pyspark/streaming/context.py @@ -92,6 +92,10 @@ def clean_up_handler(*args): for sig in (SIGINT, SIGTERM): signal(sig, clean_up_handler) + @property + def sparkContext(self): + return self._sc + def start(self): """ Start the execution of the streams.