在Hadoop中并行Ruby还原程序?

Ruby中的简单字数缩减器如下所示:

#!/usr/bin/env ruby
wordcount = Hash.new
STDIN.each_line do |line|
keyval = line.split("|")
wordcount[keyval[0]] = wordcount[keyval[0]].to_i+keyval[1].to_i
end

wordcount.each_pair do |word,count|
puts "#{word}|#{count}"
end

它在STDIN中获取所有映射器的中间值。不是从一个特定的键。 所以实际上只有一个reducer(不是每个单词或每组单词的reducer)。

然而,在Java示例中,我看到了这个接口,它以inout的形式获取键和值列表。这意味着中间映射值在reduce和reducer并行运行之前按键分组:

public static class Reduce extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntWritable> {
            public void reduce(Text key, Iterator<IntWritable> values, OutputCollector<Text, IntWritable> output, Reporter reporter) throws IOException {
              int sum = 0;
              while (values.hasNext()) {
                sum += values.next().get();
              }
              output.collect(key, new IntWritable(sum));
            }
          }

这是Java特有的特性吗?或者我可以通过使用Ruby的Hadoop流媒体来实现吗?