Difference between revisions of "MapReduce Frameworks Lab"
Jump to navigation
Jump to search
| Line 2: | Line 2: | ||
public void emit(K key, V value) | public void emit(K key, V value) | ||
| − | = | + | =Word Count Application= |
| − | |||
==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() | ||
| + | ==Test== | ||
| + | TestWordCountApplicationWithInstructorFramework | ||
| − | = | + | =Mutual Friends Application= |
| − | |||
==MutualFriendsMapper== | ==MutualFriendsMapper== | ||
public void map(MapContext<OrderedPair<AccountId>, List<AccountId>> context, Account account) | public void map(MapContext<OrderedPair<AccountId>, List<AccountId>> context, Account account) | ||
==MutualFriendsReducer== | ==MutualFriendsReducer== | ||
public FinishAccumulator<List<AccountId>> createAccumulator() | public FinishAccumulator<List<AccountId>> createAccumulator() | ||
| + | ==Test== | ||
| + | TestMutualFriendsApplicationWithInstructorFramework | ||
Revision as of 22:56, 27 February 2017
Contents
StudentIndividualMapContext
public void emit(K key, V value)
Word Count Application
WordCountMapper
public void map(MapContext<String, Integer> context, String[] lineOfWords)
WordCountReducer
public FinishAccumulator<Integer> createAccumulator()
Test
TestWordCountApplicationWithInstructorFramework
Mutual Friends Application
MutualFriendsMapper
public void map(MapContext<OrderedPair<AccountId>, List<AccountId>> context, Account account)
MutualFriendsReducer
public FinishAccumulator<List<AccountId>> createAccumulator()
Test
TestMutualFriendsApplicationWithInstructorFramework
