Hadoop MapReduce에서 Map 출력 값으로 Object를 어떻게 설정합니까?

Question

Hadoop MapReduce에서 중간 출력 (map()에 의해 생성 됨)에 대해 중간 출력의 값을 다음 객체로 지정합니다.

MyObject{ 
    date:Date 
    balance:Double 
} 

어떻게하면됩니까? 내 Writable 클래스를 만들어야 하나?

저는 MapReduce의 초보자입니다.

감사합니다.

Answer 1

방출 할 수있는 사용자 정의 유형을 매퍼 값으로 쓸 수 있습니다. 그러나 값으로 내보내려는 것이면 Writable Interface를 구현해야합니다. 다음과 같이 할 수 있습니다.

public class MyObj implements WritableComparable<MyObj>{ 

    private String date; 
    private Double balance; 

    public String getDate() { return date;} 
    public Double getBalance() { return balance;} 

    @Override 
    public void readFields(DataInput in) throws IOException { 

     //Define how you want to read the fields 
     } 
    @Override 
    public void writeFields(DataOutput out) throws IOException { 

     //Define how you want to write the fields 
    } 
     ....... 
     ....... 
     ....... 

} 

또는 Avro 직렬화 프레임 워크를 사용할 수 있습니다.