package com.sprirt.mapreduce.writable; import org.apache.hadoop.io.Writable; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; /** * 1 定义类实现writable接口 * 2 重写序列化和反序列化方法 * 3 重写空参构造 * 4 toString方法 */ public class FlowBean implements Writable { private long upFlow; // 上行流量 private long downFlow; // 下行流量 private long sumFlow; // 总流量 // 空参构造 public FlowBean() { } public long getUpFlow() { return upFlow; } public void setUpFlow(long upFlow) { this.upFlow = upFlow; } public long getDownFlow() { return downFlow; } public void setDownFlow(long downFlow) { this.downFlow = downFlow; } public long getSumFlow() { return sumFlow; } public void setSumFlow(long sumFlow) { this.sumFlow = sumFlow; } public void setSumFlow() { this.sumFlow = this.upFlow + this.downFlow; } @Override public void write(DataOutput dataOutput) throws IOException { out.writeLong(upFlow); out.writeLong(downFlow); out.writeLong(sumFlow); } @Override public void readFields(DataInput dataInput) throws IOException { this.upFlow = in.readLong(); this.downFlow = in.readLong(); this.sumFlow = in.resdLong(); } @Override public String toString() { return upFlow + "\t" + downFlow + "\t" + sumFlow; } }
时间: 2023-05-23 20:06:18 浏览: 94
A:这是一个定义实现Writable接口的Java类FlowBean,其中包含了三个属性upFlow、downFlow和sumFlow,分别表示上行流量、下行流量和总流量。该类重写了Writable接口的序列化和反序列化方法,以便对象的数据可以在Hadoop分布式系统间传输。同时,该类也实现了空参构造方法和toString方法,方便对象的初始化和字符串表示。
相关问题
C:\Users\dei'i\IdeaProjects1\MapReduceDemo\src\main\java\com\sprirt\mapreduce\writable\FlowBean.java:56:9 java: 找不到符号 符号: 变量 out
A:这个错误提示意味着编译器无法找到名为“out”的变量。通常在这种情况下,这是因为您没有正确地初始化或声明这个变量。请确保您在代码中正确地声明、初始化和使用变量“out”,或者检查您的导入语句是否正确。如果问题仍然存在,请参考具体的错误信息和代码,以便更好地理解问题的根本原因。
阅读全文