매퍼에서 문자열을 값으로 전달하는 방법은 무엇입니까?

Question

매퍼에서 문자열을 값으로 전달하려고 시도했지만 쓰기가 불가능하다는 오류가 발생했습니다. 해결 방법?

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

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

    //using Integer.parseInt to calculate profit 
    int Amount = Integer.parseInt(SingleRecord[7]); 
    int Asset = Integer.parseInt(SingleRecord[8]); 
    int SalesPrice = Integer.parseInt(SingleRecord[9]); 
    int Profit = Amount*(SalesPrice-Asset); 

    String ValueProfit = String.valueOf(Profit); 
    String ValueOne = String.valueOf(one); 

    custID.set(SingleRecord[2]); 
    data.set(ValueOne + ValueProfit); 
    context.write(custID, data); 

} 

Answer 1

야후의 튜토리얼은 말한다 : 또는 파일로부터 네트워크를 통해 마샬링 할 수
객체는 하둡이 직렬화 된 형태로 데이터를 읽고 쓸 수 있도록 쓰기 가능라는 특정 인터페이스를, 순종해야 전송 용. 클라우 데라의 사이트에서

:
키와 값 클래스는 쓰기 가능 인터페이스를 구현해야합니다 따라서 프레임 워크에 의해 직렬화 가능해야합니다. 또한 키 클래스는 정렬을 용이하게하기 위해 WritableComparable 인터페이스를 구현해야합니다.

따라서 구현을 Writable으로 설정해야 문맥에서 값으로 쓸 수 있습니다. Hadoop에는 IntWritable과 같은 몇 가지 클래스가 있습니다. 찾고있는 해당 String은 Text 클래스입니다. 그것은으로 사용할 수 있습니다

context.write(custID, new Text(data)); 

또는

Text outValue = new Text(); 
val.set(data); 
context.write(custID, outValue) 

I의 경우, 당신은 값 클래스에 특화된 기능이 필요, 당신은 Writable (안 큰 문제가 결국)를 구현 할 수 있습니다. 그러나 Text처럼 보이면 충분합니다.

Answer 2

위의 가져 오기 텍스트에 따라지도 기능에서 데이터를 설정하지 않아도 TextWritable이 잘못되었습니다. 텍스트도 사용하십시오.