Package org.apache.hadoop.hbase.codec

Class BaseDecoder

java.lang.Object

org.apache.hadoop.hbase.codec.BaseDecoder

All Implemented Interfaces:

CellScanner, Codec.Decoder, ExtendedCellScanner

Direct Known Subclasses:

CellCodec.CellDecoder, CellCodecWithTags.CellDecoder, KeyValueCodec.KeyValueDecoder, KeyValueCodecWithTags.KeyValueDecoder, MessageCodec.MessageDecoder, WALCellCodec.CompressedKvDecoder

@LimitedPrivate({"Coprocesssor","Phoenix"})
public abstract class BaseDecoder
extends Object
implements Codec.Decoder

Base implementation for Codec.Decoder.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	BaseDecoder.PBIS

Field Summary

Fields

Modifier and Type	Field	Description
private ExtendedCell	current
protected final InputStream	in
protected static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
BaseDecoder(InputStream in)

Method Summary

Modifier and Type	Method	Description
boolean	advance()	Advance the scanner 1 cell.
ExtendedCell	current()	Returns the current Cell which may be mutable
protected InputStream	getInputStream()
protected abstract ExtendedCell	parseCell()	Extract a Cell.
private void	rethrowEofException(IOException ioEx)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

in

protected final InputStream in

current

private ExtendedCell current

Constructor Details

BaseDecoder

public BaseDecoder(InputStream in)

Method Details

advance

public boolean advance()
                throws IOException

Description copied from interface: CellScanner

Advance the scanner 1 cell.

Specified by:

advance in interface CellScanner

Returns:

true if the next cell is found and CellScanner.current() will return a valid Cell

Throws:

IOException - if advancing the scanner fails

rethrowEofException

private void rethrowEofException(IOException ioEx)
                          throws IOException

Throws:

IOException

getInputStream

protected InputStream getInputStream()

parseCell

@NonNull
protected abstract ExtendedCell parseCell()
                                   throws IOException

Extract a Cell.

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

current

public ExtendedCell current()

Description copied from interface: CellScanner

Returns the current Cell which may be mutable

Specified by:

current in interface CellScanner

Specified by:

current in interface ExtendedCellScanner