Hi , I am not able to understand how aggregate function works, Can some one please explain how below result came I am running spark using cloudera VM
The result in below is 17 but i am not able to find out how it is calculating 17 val data = sc.parallelize(List(2,3,4)) data.aggregate(0)((x,y) => x+y,(x,y) => 2+x+y) *res21: Int = 17* Also when i try to change the 2nd parameter in sc.parallelize i get different result val data = sc.parallelize(List(2,3,4),2) data.aggregate(0)((x,y) => x+y,(x,y) => 2+x+y) *res21: Int = 13* Thanks for the help. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/How-Does-aggregate-work-tp22179.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
