Hadoop自定义对象序列化Writable和WritableComparable

IT 文章5年前 (2021)发布 小编
0 0 0

自定义对象根据Key和Value分为二种情况

[v_act]1. bean放在value中传输[/v_act]
如果需要将自定义的bean放在value中传输,则实现Writable接口,自定义的bean实现 的接口应该是:

public class  FlowBean  implements   Writable

[v_act]2 . bean放在key中传输[/v_act]
如果需要将自定义的bean放在key中传输,则实现WritableComparable接口,因为mapreduce框中的shuffle过程一定会对key进行排序,此时,自定义的 bean实现的接口应该是:

public class  FlowBean  implements  WritableComparable

WritableComparable源码:

ad

程序员导航

优网导航旗下整合全网优质开发资源,一站式IT编程学习与工具大全网站

public interface WritableComparable extends Writable, Comparable {}

这两种自定义类型,我们会在后面的案例中有具体使用。

© 版权声明

相关文章

暂无评论

暂无评论...