hadoop - 古い API から新しい API へ

Question

私の元の質問

その質問に対する唯一の実行可能な ans は This Question にあり、答えは古い API にあります。そのため、これらの行をNew APIに変換するという愚かな質問をする必要があります。

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 )
    {

    }

ありがとう ：） ：）

Answer 1

このプレゼンテーションは、古い API と新しい API の間の変更点をまとめたものです。