我正在尝试在自定义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()