Package org.apache.hadoop.hbase.regionserver.wal

Class WALCellCodec.CompressedKvDecoder

java.lang.Object

org.apache.hadoop.hbase.codec.BaseDecoder

org.apache.hadoop.hbase.regionserver.wal.WALCellCodec.CompressedKvDecoder

All Implemented Interfaces:

CellScanner, Codec.Decoder, ExtendedCellScanner

Enclosing class:

WALCellCodec

static class WALCellCodec.CompressedKvDecoder
extends BaseDecoder

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.codec.BaseDecoder

BaseDecoder.PBIS

Field Summary

Fields

Modifier and Type	Field	Description
private final CompressionContext	compression
private final boolean	hasTagCompression
private final boolean	hasValueCompression

Fields inherited from class org.apache.hadoop.hbase.codec.BaseDecoder

in, LOG

Constructor Summary

Constructors

Constructor	Description
CompressedKvDecoder(InputStream in, CompressionContext compression)

Method Summary

Modifier and Type	Method	Description
private static void	checkLength(int len, int max)
protected ExtendedCell	parseCell()	Extract a Cell.
private void	readCompressedValue(InputStream in, byte[] outArray, int outOffset, int expectedLength)
private int	readIntoArray(byte[] to, int offset, Dictionary dict)

Methods inherited from class org.apache.hadoop.hbase.codec.BaseDecoder

advance, current, getInputStream

Methods inherited from class java.lang.Object

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

Field Details

compression

private final CompressionContext compression

hasValueCompression

private final boolean hasValueCompression

hasTagCompression

private final boolean hasTagCompression

Constructor Details

CompressedKvDecoder

public CompressedKvDecoder(InputStream in,
 CompressionContext compression)

Method Details

parseCell

protected ExtendedCell parseCell()
                          throws IOException

Description copied from class: BaseDecoder

Extract a Cell.

Specified by:

parseCell in class BaseDecoder

Returns:

a parsed Cell or throws an Exception. EOFException or a generic IOException maybe thrown if EOF is reached prematurely. Does not return null.

Throws:

IOException

readIntoArray

private int readIntoArray(byte[] to,
 int offset,
 Dictionary dict)
                   throws IOException

Throws:

IOException

checkLength

private static void checkLength(int len,
 int max)
                         throws IOException

Throws:

IOException

readCompressedValue

private void readCompressedValue(InputStream in,
 byte[] outArray,
 int outOffset,
 int expectedLength)
                          throws IOException

Throws:

IOException