我是hadoop的新手。我正在尝试在以下代码中向reducer发送2个浮点参数。mapper成功地将参数传递给reducer但是如果我开始运行reducer空指针异常抛出..任何人都可以帮助我。提前致谢。publicclassMaxTemperatureextendsConfiguredimplementsTool{publicstaticclassMapMapperextendsMapper{publicvoidmap(LongWritablekey,Textvalue,Contextcontext)throwsIOException,InterruptedException{Str
我是ApacheHadoop的初学者,尝试了Apache的字数统计程序,它运行良好。但是现在我想制作自己的室外温度程序来计算每日平均值。平均计算不符合我的预期;没有对数据进行合并和平均。更具体地说,这里是我的sample2.txt输入文件的一部分:2502201600:00:00-10.32502201600:01:00-10.32502201600:02:00-10.32502201600:03:00-10.3...2502201600:59:00-11.2我想要的输出应该是:250220167.9这是该日期所有温度观测值的平均值。所以我有60个观察值,想要一个平均值。将来我想用同一
我想取输入文件中给出的温度的平均值,我的Mapper和Reducer语法对我来说似乎没问题,但我仍然收到以下错误:UnabletoloadrealminfofromSCDynamicStore13/02/1708:03:28INFOmapred.JobClient:TaskId:attempt_201302170552_0009_m_000000_1,Status:FAILEDjava.lang.ClassCastException:org.apache.hadoop.io.LongWritablecannotbecasttoorg.apache.hadoop.io.IntWritab