Difference between revisions of "MapReduce Frameworks Lab"
Jump to navigation
Jump to search
| Line 3: | Line 3: | ||
=WordCount= | =WordCount= | ||
| + | TestWordCountApplicationWithInstructorFramework | ||
==WordCountMapper== | ==WordCountMapper== | ||
public void map(MapContext<String, Integer> context, String[] lineOfWords) | public void map(MapContext<String, Integer> context, String[] lineOfWords) | ||
==WordCountReducer== | ==WordCountReducer== | ||
public FinishAccumulator<Integer> createAccumulator() | public FinishAccumulator<Integer> createAccumulator() | ||
Revision as of 22:48, 27 February 2017
StudentIndividualMapContext
public void emit(K key, V value)
WordCount
TestWordCountApplicationWithInstructorFramework
WordCountMapper
public void map(MapContext<String, Integer> context, String[] lineOfWords)
WordCountReducer
public FinishAccumulator<Integer> createAccumulator()
