Package org.apache.hadoop.hbase.mapreduce

Class ExtendedCellSerialization

java.lang.Object

org.apache.hadoop.hbase.mapreduce.ExtendedCellSerialization

All Implemented Interfaces:

org.apache.hadoop.io.serializer.Serialization<ExtendedCell>

@Private
public class ExtendedCellSerialization
extends Object
implements org.apache.hadoop.io.serializer.Serialization<ExtendedCell>

Similar to CellSerialization, but includes the sequenceId from an ExtendedCell. This is necessary so that CellSortReducer can sort by sequenceId, if applicable. Note that these two serializations are not compatible -- data serialized by CellSerialization cannot be deserialized with ExtendedCellSerialization and vice versa. This is ok for HFileOutputFormat2 because the serialization is not actually used for the actual written HFiles, just intermediate data (between mapper and reducer of a single job).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ExtendedCellSerialization.ExtendedCellDeserializer
static class	ExtendedCellSerialization.ExtendedCellSerializer

Constructor Summary

Constructors

Constructor	Description
ExtendedCellSerialization()

Method Summary

Modifier and Type	Method	Description
boolean	accept(Class<?> c)
ExtendedCellSerialization.ExtendedCellDeserializer	getDeserializer(Class<ExtendedCell> t)
ExtendedCellSerialization.ExtendedCellSerializer	getSerializer(Class<ExtendedCell> c)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ExtendedCellSerialization

public ExtendedCellSerialization()

Method Details

accept

public boolean accept(Class<?> c)

Specified by:

accept in interface org.apache.hadoop.io.serializer.Serialization<ExtendedCell>

getDeserializer

public ExtendedCellSerialization.ExtendedCellDeserializer getDeserializer(Class<ExtendedCell> t)

Specified by:

getDeserializer in interface org.apache.hadoop.io.serializer.Serialization<ExtendedCell>

getSerializer

public ExtendedCellSerialization.ExtendedCellSerializer getSerializer(Class<ExtendedCell> c)

Specified by:

getSerializer in interface org.apache.hadoop.io.serializer.Serialization<ExtendedCell>