Red de conocimiento informático - Problemas con los teléfonos móviles - ¿Cuál es la diferencia entre mapToPair y transformToPair de JavaPairDStream en Spark?

¿Cuál es la diferencia entre mapToPair y transformToPair de JavaPairDStream en Spark?

def mapToPair[K2, V2](f: PairFunction[T, K2, V2]): JavaPairDStream[K2, V2]

Devuelve un nuevo flujo de datos aplicando una función a todos los elementos del flujo de datos.

def transformToPair[K2, V2](transformFunc: Function2[R, Time, JavaPairRDD[K2, V2]]): JavaPairDStream[K2, V2]

Devolver un nuevo flujo de datos donde cada RDD se genera aplicando una función a cada RDD de "este" flujo de datos.

def transformToPair[K2, V2](transformFunc: Function[R, JavaPairRDD[K2, V2]]): JavaPairDStream[K2, V2]

Devuelve un nuevo flujo de datos, cada uno de estos RDD se genera aplicando una función a cada RDD del "este" flujo de datos.