MapReduce Frameworks Lab

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