pyspark.streaming.DStream.context¶

DStream.context() → StreamingContext[source]¶

Return the StreamingContext associated with this DStream

previous

pyspark.streaming.DStream.combineByKey

next

pyspark.streaming.DStream.count