pyspark.streaming.StreamingContext.getOrCreate

classmethod StreamingContext。 getOrCreate ( checkpointPath:str,setupFunc:可調用的(],StreamingContext] )→pyspark.streaming.context.StreamingContext

從檢查點數據重建StreamingContext或創建一個新的StreamingContext。如果檢查點數據存在於所提供的checkpointPath,然後從檢查站StreamingContext將重新創建數據。如果數據不存在,那麼提供setupFunc將用於創建一個新的上下文。

參數
checkpointPath str

檢查點目錄用於早期流程序

setupFunc 函數

和設置DStreams函數來創建一個新的上下文