¿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.