上传者: 38696339
|
上传时间: 2021-12-22 13:36:04
|
文件大小: 39KB
|
文件类型: -
序列化/反序列化机制
当自定义一个类之后,如果想要产生的对象在hadoop中进行传输,那么需要 这个类实现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;
private String