Thank you for reaching out.

#!/usr/bin/python
import sys

prev _word = None
prev_count = 0
word = None

# Process each key-value pair from the mapper

for line in sys.stdin:
  # Get the key and value from the current line
  line = line.strip() #remove leading and trailing whitespace
  word, count = line.split('\t')
  count = int (count) #Convert the count to an int

  # If the current word is the same as the previous word,
  # increment its count, otherwise print the words count
  # to stdout
  if word == prev_word:
    prev_count += count
  else:
    # Write word and its number of occurrences as a key-value
    #pair to stdout if prev word:
    print '(e)\t(1)',format(prev_word, prev_count)
  prev_word = word
  prev count = count

# Output the count for the last word
if prev word == word:
  print '(0)\t(1}'.format(prev_word, prev_count)
Writing Your First Map Reduce Program In Hadoop Using Python
218
2
Shobhit Agarwal
Shobhit Agarwal
·Follow
Nov 20, 2024
--
Thank you for reaching out.
Since the post is too old, I was not able to recall the drive, but I have updated the article with the wordcount_reducer.py file. For ease I have highlighted the code. I hope this helps.
--
--
Written by Shobhit Agarwal1.4K Followers
·1.2K Following
🚀 Data Scientist | AI & ML | R&D 🤖 Generative AI | LLMs | Computer Vision ⚡ Deep Learning | Python 🔗 Let’s Connect: topmate.io/shobhit_agarwal
No responses yet
Help
Status
About
Careers
Press
Blog
Privacy
Terms
Text to speech
Teams