@InterfaceAudience.Private public class ProtobufWALStreamReader extends AbstractProtobufWALReader implements WALStreamReader, AbstractFSWALProvider.Initializer
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
byteStringUncompressor, cellDecoder, codecClsName, compressionCtx, conf, decryptor, DEFAULT_WAL_TRAILER_WARN_SIZE, fileLength, fs, hasCompression, hasTagCompression, hasValueCompression, inputStream, path, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerPresent, trailerWarnSize, valueCompressionType, WAL_TRAILER_WARN_SIZE, walEditsStopOffset
Constructor and Description |
---|
ProtobufWALStreamReader() |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
getCellCodecInputStream(org.apache.hadoop.fs.FSDataInputStream stream)
Get or create the input stream used by cell decoder.
|
WAL.Entry |
next(WAL.Entry reuse)
Read the next entry in WAL, use the given
WAL.Entry if not null to hold the
data. |
protected void |
skipTo(long position)
Skip to the given position.
|
close, extractHiddenEof, getCodecClsName, getPosition, getPositionQuietly, getWriterClsNames, init, initWALCellCodec, isWALTrailer, open, reachWALEditsStopOffset, readHeader, readTrailer, trailerSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getPosition, next
init
private static final org.slf4j.Logger LOG
public ProtobufWALStreamReader()
public WAL.Entry next(WAL.Entry reuse) throws IOException
WALStreamReader
WAL.Entry
if not null
to hold the
data.
Mainly used in MR.next
in interface WALStreamReader
reuse
- the entry to be used for reading, can be null
IOException
protected InputStream getCellCodecInputStream(org.apache.hadoop.fs.FSDataInputStream stream)
AbstractProtobufWALReader
getCellCodecInputStream
in class AbstractProtobufWALReader
protected void skipTo(long position) throws IOException
AbstractProtobufWALReader
skipTo
in class AbstractProtobufWALReader
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.