自定义对象根据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源码:

程序员导航
优网导航旗下整合全网优质开发资源,一站式IT编程学习与工具大全网站
public interface WritableComparableextends Writable, Comparable {}
这两种自定义类型,我们会在后面的案例中有具体使用。
© 版权声明
文章版权归作者所有,未经允许请勿转载。
相关文章
暂无评论...



