java - 来自 TaskAttemptContext 的 JobConf

Question

我正在尝试掌握JobConf一个自定义TextInputFormat类。

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

我该怎么做？

请使用 Hadoop 0.20 API（Amazon EMR 要求）

Answer 1

TaskAttemptContext 有一个 getJobConf 方法，它返回 JobConf：

• org.apache.hadoop.mapred.TaskAttemptContext.getJobConf()