您的位置:首页 > 运维架构

hadoop自定义序列化

2015-10-02 11:36 288 查看
hadoop的MR中的m和r阶段的kv键值对都需要实现序列化,hadoop自带的Text,LongWriable...等,有时候需要自定义java数据类型作为key value,下面实现一个最简单的序列化实现。

package Test;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import org.apache.hadoop.io.Writable;
public class TestWritable implements Writable{
long id = 0L;
public TestWritable(){
super();
}
public TestWritable(long id){
super();
this.id = id;
}
@Override
public void write(DataOutput out) throws IOException {
out.writeLong(id);
}
@Override
public void readFields(DataInput in) throws IOException {
this.id = in.readLong();
}
@Override
public String toString() {
return ""+id;
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: