spark1.4 taskcontext如何初始化

Question

spark1.4 taskcontext如何初始化

Answer 1

具体解释如下

在spark1.0以上版本如果你使用new 系统会提示一下错误

这说明TaskContext 是一个抽象类，是无法被new出来的，如果你需要TaskContext来运行任务 应使用 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()