org.apache.hadoop.hbase.replication.regionserver

Class ReplicationWALReaderManager

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationWALReaderManager

@InterfaceAudience.Private
public class ReplicationWALReaderManager
extends Object

Wrapper class around WAL to help manage the implementation details such as compression.

Constructor Summary

Constructors

Constructor and Description
ReplicationWALReaderManager(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf) Creates the helper but doesn't open any file Use setInitialPosition after using the constructor if some content needs to be skipped

Method Summary

Methods

Modifier and Type	Method and Description
void	closeReader() Close the current reader
long	currentTrailerSize()
long	getPosition() Get the position that we stopped reading at
WAL.Reader	openReader(org.apache.hadoop.fs.Path path) Opens the file at the current position
WAL.Entry	readNextAndSetPosition() Get the next entry, returned and also added in the array
void	seek() Advance the reader to the current position
void	setPosition(long pos)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationWALReaderManager

public ReplicationWALReaderManager(org.apache.hadoop.fs.FileSystem fs,
                           org.apache.hadoop.conf.Configuration conf)

Creates the helper but doesn't open any file Use setInitialPosition after using the constructor if some content needs to be skipped

Parameters:

fs -

conf -

Method Detail

openReader

public WAL.Reader openReader(org.apache.hadoop.fs.Path path)
                      throws IOException

Opens the file at the current position

Parameters:

path -

Returns:

an WAL reader.

Throws:

IOException

readNextAndSetPosition

public WAL.Entry readNextAndSetPosition()
                                 throws IOException

Get the next entry, returned and also added in the array

Returns:

a new entry or null

Throws:

IOException

seek

public void seek()
          throws IOException

Advance the reader to the current position

Throws:

IOException

getPosition

public long getPosition()

Get the position that we stopped reading at

Returns:

current position, cannot be negative

setPosition

public void setPosition(long pos)

currentTrailerSize

public long currentTrailerSize()

closeReader

public void closeReader()
                 throws IOException

Close the current reader

Throws:

IOException