pyspark.streaming.StreamingContext.getActiveOrCreate¶
-
classmethod
StreamingContext。getActiveOrCreate( checkpointPath:str,setupFunc:可調用的(],StreamingContext] )→pyspark.streaming.context.StreamingContext¶ -
要麼返回活躍StreamingContext(即目前啟動但不停止),或重建StreamingContext檢查點數據或創建一個新的StreamingContext使用提供的setupFunc函數。如果checkpointPath沒有或不包含有效的檢查點數據,然後setupFunc將調用和設置DStreams創建一個新的上下文。
- 參數
-
- checkpointPath str
-
檢查點目錄用於早期流程序。可以沒有如果總是創建一個新的上下文的目的是當沒有活躍的上下文。
- setupFunc 函數
-
函數創建一個新的DStreams JavaStreamingContext和設置