Cómo inicializar el contexto de tareas de Spark1.4
Estoy muy feliz de responder a su pregunta. Revisé la documentación oficial de Spark y la explicación es la siguiente.
En Spark 1.0 o superior, si usa nuevo, el sistema le indicará. un error
Esto significa que TaskContext es una clase abstracta y no puede ser nueva. Si necesita usar TaskContext para ejecutar tareas, ¿debería usar? Si necesita usar TaskContext para ejecutar tareas, ¿debería usar? org.apache.spark.TaskContext Get() de esta manera
A continuación se muestra el código fuente y la explicación de TaskContext
public?abstract?class?TaskContext
extiende?Objeto
implementa?Para acceder al TaskContext de una tarea en ejecución, utilice:
org.apache.spark.TaskContext.get()
Esperamos su adopción, ¡gracias!