Hadoop MapReduce 基础案例及代码（第二部分）
5星
- 浏览量: 0
- 大小:None
- 文件类型：None
简介：
当自定义一个类之后，若希望其产生的对象能够在 Hadoop 中进行传输，则需要该类实现 Writable 接口以进行序列化和反序列化操作。以下是一个案例，展示了如何通过序列化/反序列化统计每个人产生的总流量数据：源自定义类序列化涉及使用 Java 的 `DataInput` 和 `DataOutput` 接口，以及 `Writable` 接口的继承。例如，以下 Java 类 `Flow` 通过实现 `Writable` 接口完成了序列化和反序列化的功能：
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import org.apache.hadoop.io.Writable;
public class Flow implements Writable {
private String phone;
public void setPhone(String phone) {
this.phone = phone;
}
public String getPhone() {
return phone;
}
@Override
public void write(DataOutput out) throws IOException {
out.writeString(phone);
}
@Override
public void read(DataInput in) throws IOException {
phone = in.readString();
}
全部评论 (0)
