实现 MapReduce 框架的序列化

|字段中文释义|字段英文释义|数据类型||------------|------------|--------||手机号|phone|String||上行流量|upflow|Long||下行流量|downflow|Long|

packagecom.xiaowang.sum;
importjava.io.DataInput;
importjava.io.DataOutput;
importjava.io.IOException;
importorg.apache.hadoop.io.Writable;
publicclassFlowBeanimplementsWritable {
privatelongupFlow;
privatelongdownFlow;
privatelongsumFlow;
// 序列化框架在反序列化操作创建对象实例时会调用无参构造器publicFlowBean() {
super();
    }
// 为了对象数据的初始化方便，加入一个带参的构造函数publicFlowBean(longupFlow, longdownFlow) {
super();
this.upFlow=upFlow;
this.downFlow=downFlow;
this.sumFlow=upFlow+downFlow;
    }
publiclonggetUpFlow() {
returnupFlow;
    }
publicvoidsetUpFlow(longupFlow) {
this.upFlow=upFlow;
    }
publiclonggetDownFlow() {
returndownFlow;
    }
publicvoidsetDownFlow(longdownFlow) {
this.downFlow=downFlow;
    }
publiclonggetSumFlow() {
returnsumFlow;
    }
publicvoidsetSumFlow(longsumFlow) {
this.sumFlow=sumFlow;
    }
// 序列化方法@Overridepublicvoidwrite(DataOutputout) throwsIOException {
out.writeLong(upFlow);
out.writeLong(downFlow);
out.writeLong(sumFlow);
    }
// 反序列化方法// 注意：字段的反序列化顺序与序列化时的顺序保持一致，并且参数类型和个数也一致@OverridepublicvoidreadFields(DataInputin) throwsIOException {
this.upFlow=in.readLong();
this.downFlow=in.readLong();
this.sumFlow=in.readLong();
    }
@OverridepublicStringtoString() {
returnupFlow+"\t"+downFlow+"\t"+sumFlow;
    }
}