We use cookies to ensure you have the best browsing experience on our website. Please read our cookie policy for more information about how we use cookies.
  1. Prepare
  2. Distributed Systems
  3. MapReduce Basics
  4. Relational MapReduce Patterns #4 - Unions
  5. Discussions

Relational MapReduce Patterns #4 - Unions

  • trier1
     + 0 comments

    For the python2 version the final part of the code stub needs to be corrected to:

    if __name__ == '__main__':
    N = 0
    inputData = []
    counter = 0
    for line in sys.stdin:
        if counter > 0:
            inputData.append(json.dumps({"key":counter,"value":int(line.strip())}))
        counter += 1
    mapReducer.execute(inputData, mapper, reducer)