我正在尝试在自定义JobConf类中获取TextInputFormat

public RecordReader<LongWritable,Text> createRecordReader(InputSplit split, TaskAttemptContext context) {
 return new XmlInputFormat(split, ...jobconf...);
}

我该怎么办?

请使用Hadoop 0.20 API(Amazon EMR要求)

最佳答案

TaskAttemptContext有一个getJobConf方法,该方法返回JobConf:

  • org.apache.hadoop.mapred.TaskAttemptContext.getJobConf()
  • 10-06 02:01