빅데이터 하둡 프로그래밍 교육과정 ]소스코드 – map & insert

빅데이터 하둡 프로그래밍 교육과정 ]소스코드 – map  & insert

빅데이터 하둡 프로그래밍 교육과정 ]소스코드 – map  & insert

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

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

소스코드 – map  & insert

■ map

public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {

        String []pair = value.toString().split("\\t");

        Long lValue = (long)Integer.parseInt(pair[1].toString());

        insert(queue, pair[0], lValue, topN);

    }

■ insert

public static void insert(PriorityQueue queue, String item, Long lValue, int topN) {

    ItemFreq head = (ItemFreq)queue.peek();

    if (queue.size() < topN || head.getFreq() < lValue) {

      ItemFreq itemFreq = new ItemFreq();

      itemFreq.setItem(item);

      itemFreq.setFreq(lValue);

      queue.add(itemFreq);

      if (head != null && head.getFreq() < lValue) { // remove smallest item.

          queue.remove();

      }

    }

  }