빅데이터 하둡 프로그래밍 교육과정 ]MyMapper1.map






빅데이터 하둡 프로그래밍 교육과정 ]MyMapper1.map

실무개발자를위한 실무교육 전문교육센터학원

www.oraclejava.co.kr에 오시면 보다 다양한 강좌를 보실 수 있습니다.


MyMapper1.map


■ 2M.Title.ID가 이 Mapper에 의해 처리



■ map 함수의 키로는 Title 스트링이, 밸류로는 그 타이틀을 갖는 문서의 ID가 들어옴.



■ ID를 키로 그리고 Title+”\t”+1을 밸류로  Reducer로 넘긴다. 



public static class MyMapper1 extends Mapper<Text, Text, Text, Text> {

      @Override

      protected void map(Text key, Text value, final Context context) throws IOException, InterruptedException {

        context.write(value, new Text(key + "\t" + 1));

        context.getCounter("Stats", "Number of Title+DocID").increment(1);

      }

    }



+ Recent posts