私は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);
しかし、リデューサーは実行されていません。これについて何か助けはありますか?