org.apache.hadoop.hbase.regionserver.wal

Class ReaderBase

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.ReaderBase

All Implemented Interfaces:

Closeable, AutoCloseable, AbstractFSWALProvider.Reader, WAL.Reader

Direct Known Subclasses:

ProtobufLogReader

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
public abstract class ReaderBase
extends Object
implements AbstractFSWALProvider.Reader

Field Summary

Fields

Modifier and Type	Field and Description
protected CompressionContext	compressionContext Compression context to use reading.
protected org.apache.hadoop.conf.Configuration	conf
protected long	edit
protected boolean	emptyCompressionContext
protected long	fileLength
protected org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG
protected org.apache.hadoop.fs.Path	path

Constructor Summary

Constructors

Constructor and Description
ReaderBase() Default constructor.

Method Summary

Modifier and Type	Method and Description
protected abstract Compression.Algorithm	getValueCompressionAlgorithm() Returns Value compression algorithm for this log.
protected abstract boolean	hasCompression() Returns Whether compression is enabled for this log.
protected abstract boolean	hasTagCompression() Returns Whether tag compression is enabled for this log.
protected abstract boolean	hasValueCompression() Returns Whether value compression is enabled for this log.
void	init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FSDataInputStream stream)
protected abstract void	initAfterCompression() Initializes the compression after the shared stuff has been initialized.
protected abstract void	initAfterCompression(String cellCodecClsName) Initializes the compression after the shared stuff has been initialized.
protected abstract String	initReader(org.apache.hadoop.fs.FSDataInputStream stream) Initializes the log reader with a particular stream (may be null).
WAL.Entry	next()
WAL.Entry	next(WAL.Entry reuse)
protected abstract boolean	readNext(WAL.Entry e) Read next entry.
void	seek(long pos)
protected abstract void	seekOnFs(long pos) Performs a filesystem-level seek to a certain position in an underlying file.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.wal.WAL.Reader

getPosition, reset

Methods inherited from interface java.io.Closeable

close

Field Detail

LOG

private static final org.slf4j.Logger LOG

conf

protected org.apache.hadoop.conf.Configuration conf

fs

protected org.apache.hadoop.fs.FileSystem fs

path

protected org.apache.hadoop.fs.Path path

edit

protected long edit

fileLength

protected long fileLength

compressionContext

protected CompressionContext compressionContext

Compression context to use reading. Can be null if no compression.

emptyCompressionContext

protected boolean emptyCompressionContext

Constructor Detail

ReaderBase

public ReaderBase()

Default constructor.

Method Detail

init

public void init(org.apache.hadoop.fs.FileSystem fs,
                 org.apache.hadoop.fs.Path path,
                 org.apache.hadoop.conf.Configuration conf,
                 org.apache.hadoop.fs.FSDataInputStream stream)
          throws IOException

Specified by:

init in interface AbstractFSWALProvider.Reader

Parameters:

fs - File system.

path - Path.

conf - Configuration.

stream - Input stream that may have been pre-opened by the caller; may be null.

Throws:

IOException

next

public WAL.Entry next()
               throws IOException

Specified by:

next in interface WAL.Reader

Throws:

IOException

next

public WAL.Entry next(WAL.Entry reuse)
               throws IOException

Specified by:

next in interface WAL.Reader

Throws:

IOException

seek

public void seek(long pos)
          throws IOException

Specified by:

seek in interface WAL.Reader

Throws:

IOException

initReader

protected abstract String initReader(org.apache.hadoop.fs.FSDataInputStream stream)
                              throws IOException

Initializes the log reader with a particular stream (may be null). Reader assumes ownership of the stream if not null and may use it. Called once.

Returns:

the class name of cell Codec, null if such information is not available

Throws:

IOException

initAfterCompression

protected abstract void initAfterCompression()
                                      throws IOException

Initializes the compression after the shared stuff has been initialized. Called once.

Throws:

IOException

initAfterCompression

protected abstract void initAfterCompression(String cellCodecClsName)
                                      throws IOException

Initializes the compression after the shared stuff has been initialized. Called once.

Parameters:

cellCodecClsName - class name of cell Codec

Throws:

IOException

hasCompression

protected abstract boolean hasCompression()

Returns Whether compression is enabled for this log.

hasTagCompression

protected abstract boolean hasTagCompression()

Returns Whether tag compression is enabled for this log.

hasValueCompression

protected abstract boolean hasValueCompression()

Returns Whether value compression is enabled for this log.

getValueCompressionAlgorithm

protected abstract Compression.Algorithm getValueCompressionAlgorithm()

Returns Value compression algorithm for this log.

readNext

protected abstract boolean readNext(WAL.Entry e)
                             throws IOException

Read next entry.

Parameters:

e - The entry to read into.

Returns:

Whether there was anything to read.

Throws:

IOException

seekOnFs

protected abstract void seekOnFs(long pos)
                          throws IOException

Performs a filesystem-level seek to a certain position in an underlying file.

Throws:

IOException