Package org.apache.hadoop.hbase.io.encoding

Class FastDiffDeltaEncoder.FastDiffCompressionState

java.lang.Object

org.apache.hadoop.hbase.io.encoding.CompressionState

org.apache.hadoop.hbase.io.encoding.FastDiffDeltaEncoder.FastDiffCompressionState

Enclosing class:

FastDiffDeltaEncoder

private static class FastDiffDeltaEncoder.FastDiffCompressionState
extends CompressionState

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	prevTimestampOffset
(package private) byte[]	timestamp

Fields inherited from class org.apache.hadoop.hbase.io.encoding.CompressionState

familyLength, keyLength, prevOffset, qualifierLength, rowLength, type, valueLength

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FastDiffCompressionState()

Method Summary

Modifier and Type	Method	Description
(package private) void	copyFrom(CompressionState state)
private void	decompressFirstKV(ByteBuffer out, DataInputStream in)	Copies the first key/value from the given stream, and initializes decompression state based on it.
protected void	readTimestamp(ByteBuffer in)

Methods inherited from class org.apache.hadoop.hbase.io.encoding.CompressionState

isFirst, readKey, readKey

Methods inherited from class java.lang.Object

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

Field Details

timestamp

byte[] timestamp

prevTimestampOffset

int prevTimestampOffset

Constructor Details

FastDiffCompressionState

private FastDiffCompressionState()

Method Details

readTimestamp

protected void readTimestamp(ByteBuffer in)

Overrides:

readTimestamp in class CompressionState

copyFrom

void copyFrom(CompressionState state)

Overrides:

copyFrom in class CompressionState

decompressFirstKV

private void decompressFirstKV(ByteBuffer out,
 DataInputStream in)
                        throws IOException

Copies the first key/value from the given stream, and initializes decompression state based on it. Assumes that we have already read key and value lengths. Does not set CompressionState.qualifierLength (not used by decompression) or CompressionState.prevOffset (set by the calle afterwards).

Throws:

IOException