话不多说,让我们看代码:
Mapreduce的二次分为四个步骤:
1.封装java的Bean对象,(其实就是创建一个java类,将数据封装到对象内),下面是要排序的数据
创建java类SortBean将数据封装到对象内
这里创建SortBean对象的时需要实现WritableComparable****接口
并实现序列化与反序列化,重写Compareto方法
2.接下来是Mapper:
3.Reducer:
4.最后一步Main方法:
话不多说,让我们看代码:
Mapreduce的二次分为四个步骤:
1.封装java的Bean对象,(其实就是创建一个java类,将数据封装到对象内),下面是要排序的数据
创建java类SortBean将数据封装到对象内
这里创建SortBean对象的时需要实现WritableComparable****接口
并实现序列化与反序列化,重写Compareto方法
2.接下来是Mapper:
3.Reducer:
4.最后一步Main方法: