spark1.4 taskcontext如何初始化

Question

spark1.4 taskcontext如何初始化

Answer 1

具体解释如下在spark1.0以上版本如果你使用new 系统会提示一下错误这说明TaskContext 是一个抽象类，是无法被new出来的，如果你需要TaskContext来运行任务 应使用 org.apache.spark.TaskContext.get() 这样的方式来获取以下是TaskContext的源码 以及 解释12345public abstract class TaskContextextends Objectimplements java.io.SerializableContextual 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()