因为只有可行的ans才能在这个问题中找到这个问题,并且答案是在旧的API中找到的。因此,这迫使我向提出一个愚蠢的问题,将这一行翻译成New :
private long mapperCounter;
@Override
public void configure(JobConf conf) {
JobClient client = new JobClient(conf);
RunningJob parentJob =
client.getJob(JobID.forName( conf.get("mapred.job.id") ));
mapperCounter = parentJob.getCounters().getCounter(MAP_COUNTER_NAME);
}注意:我希望在减缩器中使用此代码,因此可用的继承函数如下:
@Override
protected void setup(Context context) throws IOException,
InterruptedException {
}
@Override
protected void cleanup(Context context) throws IOException,
InterruptedException {
}
@Override
public void run(Context context) throws IOException,
InterruptedException {
Job job=new Job(context.getConfiguration());
}
@Override
public void reduce(ImmutableBytesWritable key,Iterable<ImmutableBytesWritable> result,Context context )
{
}谢谢:)
发布于 2012-09-25 13:34:38
这表示总结了新旧API之间的变化。
https://stackoverflow.com/questions/12582810
复制相似问题