added StreamingContext.sparkContext

YanTangZhai · Aug 31, 2014 · f5bfb70 · f5bfb70
1 parent da09768
commit f5bfb70
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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.