@InterfaceAudience.LimitedPrivate(value="Configuration") public class SecureProtobufLogReader extends ProtobufLogReader
ProtobufLogReader.WALHdrContext, ProtobufLogReader.WALHdrResult| Modifier and Type | Field and Description |
|---|---|
private Decryptor |
decryptor |
private static org.apache.commons.logging.Log |
LOG |
private static List<String> |
writerClsNames |
byteStringUncompressor, cellDecoder, DEFAULT_WAL_TRAILER_WARN_SIZE, hasCompression, hasTagCompression, inputStream, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerWarnSize, WAL_TRAILER_WARN_SIZEcompressionContext, 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 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, trailerSizenext, next, seekprivate static final org.apache.commons.logging.Log LOG
private Decryptor decryptor
public List<String> getWriterClsNames()
getWriterClsNames in class ProtobufLogReaderprotected ProtobufLogReader.WALHdrContext readHeader(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder builder, org.apache.hadoop.fs.FSDataInputStream stream) throws IOException
readHeader in class ProtobufLogReaderIOExceptionprotected void initAfterCompression(String cellCodecClsName) throws IOException
ReaderBaseinitAfterCompression in class ProtobufLogReadercellCodecClsName - class name of cell CodecIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.