This commit is contained in:
sobolevn
2024-12-02 18:05:19 +00:00
committed by GitHub

View File

@@ -126,7 +126,7 @@ class SalesRanker(MRJob):
if self.within_past_week(timestamp): if self.within_past_week(timestamp):
yield (category_id, product_id), quantity yield (category_id, product_id), quantity
def reducer(self, key, value): def reducer(self, key, values):
"""Sum values for each key. """Sum values for each key.
(category1, product1), 2 (category1, product1), 2