pyspark.streaming.StreamingContext.getOrCreate¶
-
classmethod
StreamingContext。getOrCreate( checkpointPath:str,setupFunc:可調用的(],StreamingContext] )→pyspark.streaming.context.StreamingContext¶ -
從檢查點數據重建StreamingContext或創建一個新的StreamingContext。如果檢查點數據存在於所提供的checkpointPath,然後從檢查站StreamingContext將重新創建數據。如果數據不存在,那麼提供setupFunc將用於創建一個新的上下文。
- 參數
-
- checkpointPath str
-
檢查點目錄用於早期流程序
- setupFunc 函數
-
和設置DStreams函數來創建一個新的上下文