1. 程式人生 > >MapReduce中map方法write寫入引數型別和reduce型別不同

MapReduce中map方法write寫入引數型別和reduce型別不同

當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);