@InterfaceAudience.LimitedPrivate(value="Configuration") public class SecureProtobufLogReader extends ProtobufLogReader
byteStringUncompressor, cellDecoder, hasCompression, hasTagCompression, inputStream, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerWarnSize
compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path
Constructor and Description |
---|
SecureProtobufLogReader() |
Modifier and Type | Method and Description |
---|---|
List<String> |
getWriterClsNames() |
protected void |
initAfterCompression(String cellCodecClsName)
Initializes the compression after the shared stuff has been initialized.
|
protected org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrContext |
readHeader(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder builder,
org.apache.hadoop.fs.FSDataInputStream stream) |
close, getCodec, getCodecClsName, getPosition, hasCompression, hasTagCompression, init, initAfterCompression, initReader, readNext, reset, seekOnFs, trailerSize
next, next, seek
public List<String> getWriterClsNames()
getWriterClsNames
in class ProtobufLogReader
protected org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrContext readHeader(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder builder, org.apache.hadoop.fs.FSDataInputStream stream) throws IOException
readHeader
in class ProtobufLogReader
IOException
protected void initAfterCompression(String cellCodecClsName) throws IOException
ReaderBase
initAfterCompression
in class ProtobufLogReader
cellCodecClsName
- class name of cell CodecIOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.