0

私はHadoopが初めてです。私の仕事は、最高の給料を持つ従業員を見つけることです。私のfirstmapクラスでは、単語を分割し、キーと値を次のように配置しました-

outputcollector.collect("salary",salary);

レデューサーで最高給与を見つけ、出力を次のように設定しました

outputcollector.collect("max salary",maxsalary);

ここで、このレデューサーからの出力を別のマッパーで使用したいと考えています。このようなチェーンを構築しました

JobConf mapAConf = new JobConf(false);
        ChainMapper.addMapper(conf, mymap.class, LongWritable.class, Text.class, Text.class, IntWritable.class, true, mapAConf); 

JobConf reduceConf = new JobConf(false);
        ChainReducer.setReducer(conf, myreduce.class, Text.class, IntWritable.class, Text.class, IntWritable.class, true, reduceConf);

JobConf mapCConf = new JobConf(false);
       ChainReducer.addMapper(conf, LastMapper.class, Text.class, IntWritable.class, Text.class, IntWritable.class, true, mapCConf);

しかし、リデューサーは実行されていません。これについて何か助けはありますか?

4

1 に答える 1