빅데이터 하둡 프로그래밍 교육과정 ]Version 1 - reduce

빅데이터 하둡 프로그래밍 교육과정 ] Version 1 - reduce

빅데이터 하둡 프로그래밍 교육과정 ]Version 1 - reduce

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

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

Version 1 - reduce

■ Map 부분은 앞서 본 프로그램과 너무 비슷해서 건너뛴다.

 public void reduce(Text key, Iterable<Text> values, Context context)

      throws IOException, InterruptedException {

        StringBuilder toReturn = new StringBuilder();

        boolean first = true;

        for (Text val : values) {

          if (!first)

            toReturn.append(",");

          else

            first = false;

          toReturn.append(val.toString());

        }

        context.write(key, new Text(toReturn.toString()));

      }