빅데이터공부하기 Top N의 글입니다.
우선순위큐(PriorityQueue)
우선순위를 가진 항목들을 저장하는 큐
일반 FIFO 큐나 스택과는 달 리 우선 순위가 높은 데이터가 먼저 나가게됨
예제에서는 자바 util의 PriorityQueue 클래스를 이용
- PriorityQueue에 저장될 개체타입을 ITemFreq로 정의하고 초기 크기는 10으로 지정. 또한 개체간의 비교에 사용될 Comparator도 지정
Mapper와 reducer의 시작부분에서 두개의 변수 생성
comparator<ItemFreq>comparator=new ITemFreqComparator();
PriorityQueue<ITemFreq>queue=new PriorityQueue<ITemFreq>(10, comparator);
ItemFreq클래스
이 클래스는 PriorityQueue, Mapper와 Reducer에도 키로 사용
- WritableComparable 인터페이스 구현
'빅데이터 > 빅데이터Hadoop' 카테고리의 다른 글
| 빅데이터공부하기 54_ COUNT TRIGRAM (0) | 2014.11.17 |
|---|---|
| 빅데이터공부하기 53-3 소스코드 (0) | 2014.11.10 |
| 빅데이터공부하기 54_1 Top N (0) | 2014.11.04 |
| 빅데이터공부하기 53_1 word count v2 (0) | 2014.11.04 |
| 빅데이터공부하기 53 word count v2 (0) | 2014.11.03 |