轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.22 Hadoop序列化之自定义序列化类

喜欢ヅ旅行 2024-03-22 19:33 58阅读 0赞

### 轻松入门大数据 ###

#### 文章目录 ####

*   *  轻松入门大数据
     *   *  第4章 入门到进阶：系统玩转分布式计算框架MapReduce
         *   *  4.1 Hadoop之MapReduce
             *   *  4.1.22 Hadoop序列化之自定义序列化类

![在这里插入图片描述][91bcc602c59e45969c6ecb1119c1fa49.png_pic_center]

#### 第4章 入门到进阶：系统玩转分布式计算框架MapReduce ####

##### 4.1 Hadoop之MapReduce #####

> 1.  初识MapReduce
> 2.  MR优缺点
> 3.  MR核心思想
> 4.  官方词频统计案例分析
> 5.  MR编程规范
> 6.  MR数据类型
> 7.  词频统计分析详解
> 8.  模板方法设计模式
> 9.  序列化
> 10. Hadoop序列化之Writable
> 11. 自定义序列化案例实战
> 12. 初识InputFormat&InputSplit
> 13. InputSplit和Block的关系
> 14. InputFormat系列编程
> 15. Partitioner
> 16. Combiner
> 17. 排序
> 18. 初识OutputFormat
> 19. 自定义OutputFormat实战
> 20. 场景题之group by
> 21. 场景题之distinct
> 22. 场景题之join
> 23. Shuffle详解
> 24. MR核心组件总结

###### 4.1.22 Hadoop序列化之自定义序列化类 ######

之前我们已经把需求大概的分析了一下

![在这里插入图片描述][df873e3f3ac54d81a4457c6651d87b97.png_pic_center]

OK， 开始编码，自定义序列化类

package com.dingjiaxiong.mr.ser;
    
    import org.apache.hadoop.io.Writable;
    
    import java.io.DataInput;
    import java.io.DataOutput;
    import java.io.IOException;
    
    /**
     * @Author Ding Jiaxiong
     * @Date 5/7/23 1:31 PM
     */
    public class Access implements Writable {
        
    
        // 手机号
        private String phone;
        // 上行流量
        private long up;
        // 下行流量
        private long down;
        // 和
        private long sum;
    
        // 序列化
        @Override
        public void write(DataOutput out) throws IOException {
        
            out.writeUTF(phone);
            out.writeLong(up);
            out.writeLong(down);
            out.writeLong(sum);
        }
    
        // 反序列化
        @Override
        public void readFields(DataInput in) throws IOException {
        
            this.phone = in.readUTF();
            this.up = in.readLong();
            this.down = in.readLong();
            this.sum = in.readLong();
        }
    
        public Access(String phone, long up, long down) {
        
            this.phone = phone;
            this.up = up;
            this.down = down;
            this.sum = up + down;
        }
    
        public String getPhone() {
        
            return phone;
        }
    
        public void setPhone(String phone) {
        
            this.phone = phone;
        }
    
        public long getUp() {
        
            return up;
        }
    
        public void setUp(long up) {
        
            this.up = up;
        }
    
        public long getDown() {
        
            return down;
        }
    
        public void setDown(long down) {
        
            this.down = down;
        }
    
        public long getSum() {
        
            return sum;
        }
    
        public void setSum(long sum) {
        
            this.sum = sum;
        }
    }

![在这里插入图片描述][c9d5b70891964aa085b7c46744785251.png_pic_center]

[91bcc602c59e45969c6ecb1119c1fa49.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/bdeb881e726941bfa58d47163aa1c8e6.png
[df873e3f3ac54d81a4457c6651d87b97.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/48f5e333b1de49e48a199aff015667ea.png
[c9d5b70891964aa085b7c46744785251.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/3aa5d3fdfe9143d6a2a0a1dc62f99879.png

轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.22 Hadoop序列化之自定义序列化类

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.26 Hadoop序列化之总结

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.25 Hadoop序列化之自定义Driver类及测试

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.24 Hadoop序列化之自定义Reducer类

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.23 Hadoop序列化之自定义Mapper类

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.22 Hadoop序列化之自定义序列化类

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.21 Hadoop序列化之需求分析

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.20 Hadoop序列化之Writable接口详解

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.18 序列化之JDK自带的序列化机制

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.19 序列化之Data序列化机制

相关轻松入门大数据第4章入门到进阶：系统玩转分布式计算框架MapReduce 4.1 Hadoop之MapReduce 4.1.17 序列化概述