pyspark.RDD.barrier¶
-
抽樣。障礙( )→pyspark.rdd.RDDBarrier(T] ¶ -
標誌著當前階段作為一個障礙階段,火花必須共同推出所有任務。如果任務失敗,而不隻是重新啟動失敗的任務,火花將中止整個階段和重新啟動所有任務階段。障礙執行模式特性實驗,它隻處理有限的場景。請閱讀有關SPIP和設計文檔理解的局限性和未來的計劃。
- 返回
-
-
RDDBarrier -
實例提供了舞台行動在一個障礙。
-
筆記
更多信息請見
這個API是實驗