pyspark.streaming.DStream.context

DStream.context() → StreamingContext

Return the StreamingContext associated with this DStream

previous

pyspark.streaming.DStream.combineByKey

next

pyspark.streaming.DStream.count