¿Cómo distingue Spark entre operadores de transformación y operadores de acción?
En mi opinión, un operador de operación en la programación Spark es como un desencadenante del operador de transformación anterior. Los operadores de conversión tienen una función de carga diferida, no se cargan inmediatamente después de definir la operación, solo después de que se ejecuta el operador de operación, se ejecutan todos los operadores de conversión anteriores. El siguiente código enumera los operadores más utilizados: (versión Java)
package cn.spark.study.core
import java.util.Arrays
import; java.util.List;
importar java.util.
importar org.apache.spark.api.java.JavaPairRDD
importar apache. spark.api.java.JavaRDD
importar org.apache.spark.api.java.JavaSparkContext
importar org.apache.spark.api.java.function
p>
importar org.apache.spark.api.java.function.Function.
importar org.apache.spark.api.java.function.Function.