public class SecureProtobufLogReader extends ProtobufLogReader
byteStringUncompressor, cellDecoder, hasCompression, hasTagCompression, inputStream
compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path, trailer, trailerWarnSize
Constructor and Description |
---|
SecureProtobufLogReader() |
Modifier and Type | Method and Description |
---|---|
protected void |
initAfterCompression()
Initializes the compression after the shared stuff has been initialized.
|
protected boolean |
readHeader(WALProtos.WALHeader.Builder builder,
org.apache.hadoop.fs.FSDataInputStream stream) |
close, getCodec, getPosition, getWALTrailer, hasCompression, hasTagCompression, initReader, readNext, reset, seekOnFs
init, next, next, seek
protected boolean readHeader(WALProtos.WALHeader.Builder builder, org.apache.hadoop.fs.FSDataInputStream stream) throws IOException
readHeader
in class ProtobufLogReader
IOException
protected void initAfterCompression() throws IOException
ReaderBase
initAfterCompression
in class ProtobufLogReader
IOException
Copyright © 2014 The Apache Software Foundation. All rights reserved.