MapReduce學習(三):Hadoop序列化相關接口

1. Writable接口

(1)簡介:

Hadoop自身實現序列化就是通過實現Writable接口來完成的。

(2)Writable接口提供兩個方法(write和readFields)。

1)void write(DataOutput out) throws IOException;

Write:將一個實現了Writable接口的對象序列化成字節流

2)void readFields(DataInput in) throws IOException;

readFields:將字節流轉化為實現了Writable接口的對象

2. Writable接口的代碼實例

MapReduce學習(三):Hadoop序列化相關接口


3. 比較接口:WritableComparable

(1)需要進行數據比較的話,要實現WritableComparable接口。

public interface WritableComparable extends Writable, Comparable{ }

由此可以看到,WritableComparable是Writable接口和java.lang.Comparable的一個子接口

(2)RawComparator是Comparator的增強版

public interface RawComparator extends java.util.Comparator

4. WritableComparable接口的代碼實例

MapReduce學習(三):Hadoop序列化相關接口

MapReduce學習(三):Hadoop序列化相關接口



分享到:


相關文章: