Difference between revisions of "MapReduce Frameworks Lab"
Jump to navigation
Jump to search
| Line 8: | Line 8: | ||
==WordCountReducer== | ==WordCountReducer== | ||
public FinishAccumulator<Integer> createAccumulator() | public FinishAccumulator<Integer> createAccumulator() | ||
| + | |||
| + | =MutualFriends= | ||
| + | TestMutualFriendsApplicationWithInstructorFramework | ||
| + | ==MutualFriendsMapper== | ||
| + | public void map(MapContext<OrderedPair<AccountId>, List<AccountId>> context, Account account) | ||
| + | ==MutualFriendsReducer== | ||
| + | public FinishAccumulator<List<AccountId>> createAccumulator() | ||
Revision as of 22:51, 27 February 2017
Contents
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()
MutualFriends
TestMutualFriendsApplicationWithInstructorFramework
MutualFriendsMapper
public void map(MapContext<OrderedPair<AccountId>, List<AccountId>> context, Account account)
MutualFriendsReducer
public FinishAccumulator<List<AccountId>> createAccumulator()
