Aggregations - reduceByKey and aggregateByKey


Originally published at:

Following are the functions which can be used to perform by key transformations. reduce can be used for total aggregations. reduceByKey aggregateByKey groupByKey Using these APIs we can perform aggregations such as total revenue per day, minimum salaried employee per department, average salary per department etc. Standard aggregations are count, sum, average, standard deviation, mode,…