Foro Formación Hadoop

aggregateByKey alternativa a funciones de agrupación

 
Imagen de Cristina Cano Sandin
aggregateByKey alternativa a funciones de agrupación
de Cristina Cano Sandin - miércoles, 7 de febrero de 2018, 17:17
 

Hola soy alumna vuestra y tengo una duda que me tiene bloqueada, estoy estudiando las funciones de transformación que tiene spark y estoy intentando entender como funciona aggregateByKey(zeroValue)(seqOpcombOp, [numTasks]) y la verdad es que la entiendo, como funciona está función de transformación , es que por mas que miro ejemplos no entiendo bien como se aplican las funciones seqOpcombOp que se pasan por parámetro  en que orden se ejecutan y para que sirve zeroValue.

Sabéis de algún ejemplo de código que lo explique una forma claro el funcionamiento de las funciones de  seqOpcombOp.

 

Gracias de antemano un saludo.

Imagen de Fernando Agudo
Re: aggregateByKey alternativa a funciones de agrupación
de Fernando Agudo - lunes, 12 de febrero de 2018, 15:42
 

Hola Cristina,

¿En que leguaje necesitarías el ejemplo/explicación? ¿Python, Java o Scala?

Un saludo,