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