Switch branches/tags
Nothing to show
Find file
Fetching contributors…
Cannot retrieve contributors at this time
29 lines (19 sloc) 534 Bytes
#-*-coding: utf-8 -*-
This module computes the number of movies rated by each
__author__ = 'Marcel Caraciolo <>'
from mrjob.job import MRJob
class MoviesCount(MRJob):
def mapper(self, key, line):
Mapper: send score from a single movie to
other movies
user_id, item_id, rating = line.split('|')
yield(item_id, 1)
def reducer(self, movie, values):
yield(movie, sum(values))
if __name__ == '__main__':