var inputdata = List((1,2),(1,13),(1,4), (1, 6))
var kvrdd = sc.parallelize(inputdata)
def max(a:Int, b:Int): Int = {
if(a > b) return a;
return b
}
val out = kvrdd.reduceByKey(max)
out.collect()
XP
Taking you to the next exercise in seconds...
Want to create exercises like this yourself? Click here.
Loading comments...