как написать значения int в редукторе хауопа

Question

Я пишу mapreduce с Hadoop. В методе уменьшения, я хочу использовать 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); 
} 

Это позволяет сократить отсчитывает что-то. Затем он должен написать переменную ключа и счетчика.

Как я могу это сделать?

Ответ

Я нашел мой ответ. Я должен новый a 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));