StreamingContext。
停止
停止與選擇的執行流,確保所有接收的數據被處理。
停止SparkContext與否有關
優雅地停止等待所有接收的數據的處理完成
以前的
pyspark.streaming.StreamingContext.start
下一個
pyspark.streaming.StreamingContext.transform