作者:流浪V海哥 | 来源:互联网 | 2023-10-10 04:55
案例十:自定义实体类自定义实体类其实就是把每行需要的信息放在一起封装了对象,并且该对象必须实现Writable接口,重写write和readFields的方法,读写的顺序和
案例十:自定义实体类
自定义实体类其实就是把每行需要的信息放在一起封装了对象,并且该对象必须实现
Writable接口,重写write和readFields的方法,读写的顺序和类型都必须一致才行,
这样该实体类就相当于IntWritable或者LongWritable之类的数据类型一样了,可以作
为map和reduce的参数进行相互传递使用,当然了按照需求重写toString方法就可以
改成你需要的输出格式,用着很方便,代码看着也会很简洁。
我很喜欢这个方法,封装成一个类,看着也很舒服。
先把实体类的代码贴上:
下面是执行代码: