You are viewing a single comment's thread. Return to all comments →
inputData = [] counter = 0 for line in sys.stdin: if (counter == 0): N = int(line) else: inputData.append(json.dumps({"key":counter,"value":line})) counter += 1 mapReducer.execute(inputData, mapper, reducer)
Seems like cookies are disabled on this browser, please enable them to open this website
Relational MapReduce Patterns #2 - Selections
You are viewing a single comment's thread. Return to all comments →