Skip to content

Commit 63c881a

Browse files
committed
added StreamingContext.sparkContext
1 parent d39f102 commit 63c881a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

python/pyspark/streaming/context.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,10 @@ def clean_up_handler(*args):
9292
for sig in (SIGINT, SIGTERM):
9393
signal(sig, clean_up_handler)
9494

95+
@property
96+
def sparkContext(self):
97+
return self._sc
98+
9599
def start(self):
96100
"""
97101
Start the execution of the streams.

0 commit comments

Comments
 (0)