@InterfaceAudience.Private public class ReplicationWALReaderManager extends java.lang.Object
Constructor and Description |
---|
ReplicationWALReaderManager(FileSystem fs,
Configuration conf)
Creates the helper but doesn't open any file
Use setInitialPosition after using the constructor if some content needs to be skipped
|
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(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) |
public ReplicationWALReaderManager(FileSystem fs, Configuration conf)
fs
- conf
- public WAL.Reader openReader(Path path) throws java.io.IOException
path
- java.io.IOException
public WAL.Entry readNextAndSetPosition() throws java.io.IOException
java.io.IOException
public void seek() throws java.io.IOException
java.io.IOException
public long getPosition()
public void setPosition(long pos)
public long currentTrailerSize()
public void closeReader() throws java.io.IOException
java.io.IOException