python hadoop流中的组合函数

I have a mapper that outputs key and value , which is sorted and piped into reducer.py , I have a mapper that outputs key and value , wh