|
@@ -30,7 +30,7 @@ class SpendingByCategory(MRJob):
|
|
|
(2016-01, shopping), 100
|
|
|
(2016-01, gas), 50
|
|
|
"""
|
|
|
- timestamp, seller, amount = line.split('\t')
|
|
|
+ timestamp, category, amount = line.split('\t')
|
|
|
period = self. extract_year_month(timestamp)
|
|
|
if period == self.current_year_month():
|
|
|
yield (period, category), amount
|