Flash Sale: Flat 70% + Addl. 25% Off on all Courses | Use Coupon DS25 in Checkout | Offer Expires In

  Enroll Now

What would the following code do?

var inputdata = List((1,2.0),(1,12.0),(1,4.0), (1, 6.0))
var kvrdd = sc.parallelize(inputdata)
def avg(a:Double, b:Double): Double = {
    return (a+b)/2
}
val out = kvrdd.reduceByKey(avg)
out.collect()

Note - Having trouble with the assessment engine? Follow the steps listed here


No hints are availble for this assesment

Answer is not availble for this assesment

Loading comments...