如何在hadoop减速器中编写int值

Question

我正在用Hadoop写一个mapreduce。在reduce方法中，我想用context.write()。但是输出是int类型。我该怎么做？当我使用context.write()时，它显示一个错误:

第二个参数不能是int。

这是我的代码：

public void reduce(Text key, Iterable<NullWritable> values, Context context) throws IOException, InterruptedException {

            int count = 0;

            for (NullWritable nullWritable : values) {
                count++;
            }

             //context.write(key, count); 
}

这个减少计算一些东西。然后它应该写键和计数变量。

我该怎么做？

答复

我找到了我的答案。我应该新建一个IntWritable类并使用它的方法(set(intValue))。

类似于以下代码：

IntWritable c = new IntWritable();
    public void reduce(Text key, Iterable<NullWritable> values, Context context) throws IOException, InterruptedException {

                int count = 0;


                for (NullWritable nullWritable : values) {
                    count++;
                }

                c.set(count);
                context.write(key, c);

            }

Answer 1

您也可以这样使用它：

context.write(key,new IntWritable(count));