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. Databases
  3. NoSQL - XML, MapReduce
  4. Map Reduce Advanced - Count number of friends
  5. Discussions

Map Reduce Advanced - Count number of friends

  • charlesartbr
     + 0 comments

    Simple way:

    def mapper(record):
    f1, f2 = record.replace('\n', '').split(' ')
    mapReducer.emitIntermediate(f1, f2)
    mapReducer.emitIntermediate(f2, f1)

    def reducer(key, list_of_values):
    mapReducer.emit([key, len(list_of_values)])