데이터분석/Preprocessing
spark 아오
늘근이
2018. 5. 14. 01:46
Task not serializable: java.io.NotSerializableException
Never call sparkContext in function closure.
in.rdd.flatMap { row => Seq.fill(row.getAs[Double]("xxx").toInt + 1)(row) }