Merge 4bf44904db
into a07e261677
This commit is contained in:
commit
a4f8536e74
|
@ -126,7 +126,7 @@ class SalesRanker(MRJob):
|
|||
if self.within_past_week(timestamp):
|
||||
yield (category_id, product_id), quantity
|
||||
|
||||
def reducer(self, key, value):
|
||||
def reducer(self, key, values):
|
||||
"""Sum values for each key.
|
||||
|
||||
(category1, product1), 2
|
||||
|
|
Loading…
Reference in New Issue