首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    MapReduce当中自定义对象的用法

    马克-to-win @ 马克java社区:到目前为止,我们在hadoop网络上传的变量类型都是预定义的类型比如Text或IntWritable等,但有时需要我们,自己建一个类,把预定义的简单数据类型封装在里头而且还能像预定义的类型一样在hadoop网络中传输,这样更便于管理和运作。这样就需要向下面这样implements Writable。实现write和readFields方法。思路:如果想求平均值的话,按照前一章讲的hello world方法,同一个键的所有值,同时都进同一个reduce方法,这样的话,我们可以以字符串的形式,把o1,p2,250.0和o1,p1,200.0两个字符串同时传到同一个reduce之后,经过处理,求和求平均值就可以了,但是这种方法毕竟显得有点笨,(但基本能解决所有问题),所以我们可以用这一节所学的自定义对象的方法传值。显得高大上。讲述本节时,可以先讲一遍,明白了后,再讲一遍,说明为什么这么写程序。

    03
    领券