Only Few Seats Left for Advanced Certification Courses on Data Science, ML & AI by E&ICT Academy IIT Roorkee

  Apply Now

Apache Spark - Reduce, Commutative & Associative

  • More Actions - Reduce()

    var seq = sc.parallelize(1 to 100)
    def sum(x: Int, y:Int):Int = {return x+y}
    var total = seq.reduce(sum);


  • Using reduce for avg()

    var seq = sc.parallelize(Array(3.0, 7, 13, 16, 19))
    def avg(x: Double, y:Double):Double = {return (x+y)/2}
    var total = seq.reduce(avg);

No hints are availble for this assesment

Answer is not availble for this assesment

Loading comments...