Foro Formación Hadoop
aggregateByKey alternativa a funciones de agrupación
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)(seqOp, combOp, [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 seqOp, combOp 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 seqOp, combOp.
Gracias de antemano un saludo.
Redes sociales