user-defined-aggregate

5calore

1risposta

Perché la mappa mutevole diventa immutabile automaticamente in UserDefinedAggregateFunction (UDAF) in Spark

Sto provando a definire una UserDefinedAggregateFunction (UDAF) in Spark, che conta il numero di occorrenze per ogni valore univoco in una colonna di un gruppo. Questo è un esempio: Supponiamo che io

scala apache-spark mutable user-defined-aggregate 2016-04-14

---