Difference between revisions of "MapReduce Frameworks Lab"

From CSE231 Wiki
Jump to navigation Jump to search
(Created page with "=StudentIndividualMapContext= public void emit(K key, V value) =WordCount= ==WordCountMapper== ==WordCountReducer==")
 
Line 4: Line 4:
 
=WordCount=
 
=WordCount=
 
==WordCountMapper==
 
==WordCountMapper==
 +
public void map(MapContext<String, Integer> context, String[] lineOfWords)
 
==WordCountReducer==
 
==WordCountReducer==
 +
public FinishAccumulator<Integer> createAccumulator()

Revision as of 22:48, 27 February 2017

StudentIndividualMapContext

public void emit(K key, V value)

WordCount

WordCountMapper

public void map(MapContext<String, Integer> context, String[] lineOfWords)

WordCountReducer

public FinishAccumulator<Integer> createAccumulator()