Hadoop 감소 제 정리 기능

Question

hadoop 축소 코드에서 전체 개수를 인쇄하는 정리 기능이 있지만 두 번 인쇄됩니다. 이것은 키 + 값 및 카운트 만 계산하고 있기 때문입니다. 그러나 확실하지 않습니다. 감속기 클래스 내부

protected void cleanup(Context context) throws IOException, 
       InterruptedException { 
      Text t1 = new Text("Total Count"); 
      context.write(t1, new IntWritable(count)); 
     } 

출력은 다음과 같습니다 :

내 코드는이있다

Total Count  9477 
Total Count  4738 

Answer 1

정리 방법은 각 작업의 마지막에 호출된다. 따라서 코드에서 2 개의 감속기를 사용한다고 가정합니다. 그러므로 2 개의 출력