@InterfaceAudience.Private public class ProtobufLogReader extends ReaderBase
<PB_WAL_MAGIC><WALHeader><WALEdits>...<WALEdits><Trailer> <TrailerSize> <PB_WAL_COMPLETE_MAGIC>
The Reader reads meta information (WAL Compression state, WALTrailer, etc) ininitReader(FSDataInputStream)
. A WALTrailer is an extensible structure
which is appended at the end of the WAL. This is empty for now; it can contain some meta
information such as Region level stats, etc in future.compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path, trailer, trailerWarnSize
Constructor and Description |
---|
ProtobufLogReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
getPosition() |
WALProtos.WALTrailer |
getWALTrailer() |
protected boolean |
hasCompression() |
protected void |
initAfterCompression()
Initializes the compression after the shared stuff has been initialized.
|
protected void |
initReader(org.apache.hadoop.fs.FSDataInputStream stream)
Initializes the log reader with a particular stream (may be null).
|
protected boolean |
readNext(HLog.Entry entry)
Read next entry.
|
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 IOException
IOException
public long getPosition() throws IOException
IOException
public void reset() throws IOException
IOException
protected void initReader(org.apache.hadoop.fs.FSDataInputStream stream) throws IOException
ReaderBase
initReader
in class ReaderBase
IOException
protected void initAfterCompression() throws IOException
ReaderBase
initAfterCompression
in class ReaderBase
IOException
protected boolean hasCompression()
hasCompression
in class ReaderBase
protected boolean readNext(HLog.Entry entry) throws IOException
ReaderBase
readNext
in class ReaderBase
entry
- The entry to read into.IOException
public WALProtos.WALTrailer getWALTrailer()
getWALTrailer
in interface HLog.Reader
getWALTrailer
in class ReaderBase
protected void seekOnFs(long pos) throws IOException
ReaderBase
seekOnFs
in class ReaderBase
IOException
Copyright © 2013 The Apache Software Foundation. All rights reserved.