您的位置:首页 > 其它

MapReduce中map方法write写入参数类型和reduce类型不同

2018-01-28 18:47 447 查看
当map方法中context.write()和reduce方法中context.write()输入参数类型不相同时:
需要在job中设置每个方法的参数类型:

map中:
context.write(MyNewKey,NullWritable);

reduce中:
context.write(LongWritable,LongWritable);

那么进行如下设置即可:
job.setMapOutputKeyClass(MyNewKey.class);
job.setMapOutputValueClass(NullWritable.class);

job.setOutputKeyClass(LongWritable.class);
job.setOutputValueClass(LongWritable.class);
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
相关文章推荐