r3 sample mapper

mapper.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

from r3.worker.mapper import Mapper

class CountWordsMapper(Mapper):
    job_type = 'count-words'

    def map(self, lines):
        #time.sleep(0.5)
        return list(self.split_words(lines))

    def split_words(self, lines):
        for line in lines:
            for word in line.split():
                yield word.strip().strip('.').strip(','), 1

mapper.sh

r3-map --mapper-key="1" --mapper-class="my_app.mapper.CountWordsMapper"
r3-map --mapper-key="2" --mapper-class="my_app.mapper.CountWordsMapper"
r3-map --mapper-key="3" --mapper-class="my_app.mapper.CountWordsMapper"
r3-map --mapper-key="4" --mapper-class="my_app.mapper.CountWordsMapper"