지도 축소 기능을 사용하는 Avro를 사용하는 것에 대해 혼란스러워하며 따라야 할 좋은 자습서를 찾을 수 없습니다.일반 텍스트 입력 및 avro 출력을 사용하는 mapreduce 작업
AvroJob 및 AvroMapper와 같은 클래스는 입력 및 출력이 모두 Avro 데이터 파일 일 때 문제가 발생하는 것으로 보입니다. 귀하의 의견이 일반 텍스트 일 때는 어떻습니까?
구체적 :
내 맵퍼로 입력 LongWritable 키 및 텍스트 값 걸린다. 텍스트 키와 MyAvroRecord 값을 내 보냅니다.
내 감속기는 텍스트 키와 MyAvroRecords의 반복자를 입력으로 받아 텍스트 키와 MyAvroRecord 값을 내 보냅니다.
이러한 텍스트 키와 MyAvroRecord 값을 파일에 쓰는 OutputFormat을 어떻게 구합니까?
건배, 데이브
안녕 데이브, 나는 반대에 STH을하려고하고있다. 내 입력은 텍스트이고 출력은 일반 레코드입니다. AvroJob을위한 Avro 입력 스키마를 설정하고 출력 스키마를 일반 레코드의 스키마로 설정하려고합니다. 그러나 AvroJob이 일반 텍스트임을 이해할 수 있도록 입력 스키마를 마무리하는 방법을 모르겠습니다. setInputSchema()를 아무것도 사용하지 말아야합니까? –