spark1.4 taskcontext如何初始化
1 回答
精慕HU
TA貢獻(xiàn)1845條經(jīng)驗 獲得超8個贊
具體解釋如下
在spark1.0以上版本如果你使用new 系統(tǒng)會提示一下錯誤
這說明TaskContext 是一個抽象類，是無法被new出來的，如果你需要TaskContext來運行任務(wù) 應(yīng)使用 org.apache.spark.TaskContext.get() 這樣的方式來獲取
以下是TaskContext的源碼 以及 解釋
1 2 3 4 5 | public abstract class TaskContext extends Object implements java.io.Serializable Contextual information about a task which can be read or mutated during execution. To access the TaskContext for a running task, use: org.apache.spark.TaskContext.get() |
- 1 回答
- 0 關(guān)注
- 1068 瀏覽
添加回答
舉報
0/150
提交
取消