pyspark.streaming.DStream.context

DStream.context() → StreamingContext

Return the StreamingContext associated with this DStream

pyspark.streaming.DStream.combineByKey pyspark.streaming.DStream.count