Foro Formación Hadoop

aggregateByKey alternativa a funciones de agrupación

 
Picture of Cristina Cano Sandin
aggregateByKey alternativa a funciones de agrupación
by Cristina Cano Sandin - Wednesday, 7 February 2018, 5:17 PM
 

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.

Picture of Fernando Agudo
Re: aggregateByKey alternativa a funciones de agrupación
by Fernando Agudo - Monday, 12 February 2018, 3:42 PM
 

Hola Cristina,

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

Un saludo,