Implement MapReduce

map, shuffle, reduce with combiners

Challenge 1 of Data PipelinesIntermediate~50 minFree

Process a dataset too big for one machine by splitting the work into two simple functions. Map turns each input into key/value pairs; the framework shuffles pairs together by key; reduce collapses each key's values into a result. Build the three phases, wire them into a word-count job, and add a combiner that pre-aggregates locally, the programming model that powered Google's index and inspired Hadoop and Spark.

4 steps

  1. 1The Map Phase
  2. 2Shuffle: Grouping by Key
  3. 3The Reduce Phase
  4. 4The Full Job and a Combiner
Start step 1