@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix","Configuration"}) public class SequenceFileLogReader extends ReaderBase
Modifier and Type | Field and Description |
---|---|
protected SequenceFile.Reader |
reader |
compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path
Constructor and Description |
---|
SequenceFileLogReader() |
Modifier and Type | Method and Description |
---|---|
protected java.io.IOException |
addFileInfoToException(java.io.IOException ioe) |
void |
close() |
long |
getPosition() |
protected boolean |
hasCompression() |
protected boolean |
hasTagCompression() |
protected void |
initAfterCompression()
Initializes the compression after the shared stuff has been initialized.
|
protected void |
initAfterCompression(java.lang.String cellCodecClsName)
Initializes the compression after the shared stuff has been initialized.
|
protected java.lang.String |
initReader(FSDataInputStream stream)
Initializes the log reader with a particular stream (may be null).
|
protected boolean |
readNext(WAL.Entry e)
fill in the passed entry with teh next key/value.
|
void |
reset() |
protected void |
seekOnFs(long pos)
Performs a filesystem-level seek to a certain position in an underlying file.
|
init, next, next, seek
public void close() throws java.io.IOException
java.io.IOException
public long getPosition() throws java.io.IOException
java.io.IOException
public void reset() throws java.io.IOException
java.io.IOException
protected java.lang.String initReader(FSDataInputStream stream) throws java.io.IOException
ReaderBase
initReader
in class ReaderBase
java.io.IOException
protected void initAfterCompression(java.lang.String cellCodecClsName) throws java.io.IOException
ReaderBase
initAfterCompression
in class ReaderBase
cellCodecClsName
- class name of cell Codecjava.io.IOException
protected void initAfterCompression() throws java.io.IOException
ReaderBase
initAfterCompression
in class ReaderBase
java.io.IOException
protected boolean hasCompression()
hasCompression
in class ReaderBase
protected boolean hasTagCompression()
hasTagCompression
in class ReaderBase
protected boolean readNext(WAL.Entry e) throws java.io.IOException
HLogKey
for the key.readNext
in class ReaderBase
e
- The entry to read into.java.io.IOException
protected void seekOnFs(long pos) throws java.io.IOException
ReaderBase
seekOnFs
in class ReaderBase
java.io.IOException
protected java.io.IOException addFileInfoToException(java.io.IOException ioe) throws java.io.IOException
java.io.IOException