Mapper()에 ArrayList <String>을 전달하는 Hadoop 작업 공식

Question

일반적인 단어 수 계산 예제와 다른 Hadoop 작업을 공식화하려고합니다. 내 입력 데이터의 형식은 :

makePush,1964 
makePush,459 
makePush,357 
opAdd,2151 
opAdd,257 
opStop,135 

난 이후에 Reducer()에 기능 Mapper() 이러한 전달, 그리고 싶지만, 즉, 사양

Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT> 

을하는 데 문제가 그러면 예를 들어 opAdd은 KEYIN이고 257은 VALUEIN이됩니다. 결과적으로 모든 opAdd의 합은 KEYOUT이 될 것이며 관련 숫자의 합은 VALUEOUT이 될 것입니다.

그러나 프로그래밍 방식으로 구현하는 방법은 무엇입니까? 이론상 단어 수 (Word Count)의 예와 크게 다르지 않은 것 같습니다. 예를 들어

Answer 1

, opAdd는 KEYIN 것, 257은 VALUEIN

아니, 키가 어디에 현재 맵을 지정하는 파일의 오프셋 마커 인 LongWritable, 될 것 작업이 파일을 읽는 중입니다. 당신이 toString().split(",") 데이터를 분리하는 것 opAdd,257의 전체 라인이 될 것

가치가 될 것 텍스트,