pyspark.TaskContext¶
-
類
pyspark。TaskContext¶ -
上下文信息的任務在執行期間可以讀取或突變。訪問TaskContext運行的任務,使用:
TaskContext.get ()。方法
”
得到()返回當前活躍TaskContext。
getLocalProperty(關鍵)得到當地一個屬性集上遊的司機,或沒有失蹤。
抽樣的ID分區計算這一任務。
資源()資源分配給的任務。
stageId()階段,這個任務的ID。
一個ID,這個任務是獨一無二的嚐試(在同一個SparkContext,沒有兩個任務嚐試嚐試將共享相同的ID)。