org.apache.hadoop.hbase.regionserver.wal

Class SecureProtobufLogReader

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.ReaderBase

org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

org.apache.hadoop.hbase.regionserver.wal.SecureProtobufLogReader

All Implemented Interfaces:

Closeable, AutoCloseable, AbstractFSWALProvider.Reader, WAL.Reader

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class SecureProtobufLogReader
extends ProtobufLogReader

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

ProtobufLogReader.WALHdrContext, ProtobufLogReader.WALHdrResult

Field Summary

Fields

Modifier and Type	Field and Description
private Decryptor	decryptor
private static org.slf4j.Logger	LOG
private static List<String>	writerClsNames

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

byteStringUncompressor, cellDecoder, DEFAULT_WAL_TRAILER_WARN_SIZE, hasCompression, hasTagCompression, hasValueCompression, inputStream, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerWarnSize, valueCompressionType, WAL_TRAILER_WARN_SIZE

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.ReaderBase

compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path

Constructor Summary

Constructors

Constructor and Description
SecureProtobufLogReader()

Method Summary

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.shaded.protobuf.generated.WALProtos.WALHeader.Builder builder, org.apache.hadoop.fs.FSDataInputStream stream)

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

close, getCodec, getCodecClsName, getPosition, getValueCompressionAlgorithm, hasCompression, hasTagCompression, hasValueCompression, init, initAfterCompression, initReader, readNext, reset, seekOnFs, trailerSize

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.ReaderBase

next, next, seek

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

decryptor

private Decryptor decryptor

writerClsNames

private static List<String> writerClsNames

Constructor Detail

SecureProtobufLogReader

public SecureProtobufLogReader()

Method Detail

getWriterClsNames

public List<String> getWriterClsNames()

Overrides:

getWriterClsNames in class ProtobufLogReader

readHeader

protected ProtobufLogReader.WALHdrContext readHeader(org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader.Builder builder,
                                                     org.apache.hadoop.fs.FSDataInputStream stream)
                                              throws IOException

Overrides:

readHeader in class ProtobufLogReader

Throws:

IOException

initAfterCompression

protected void initAfterCompression(String cellCodecClsName)
                             throws IOException

Description copied from class: ReaderBase

Initializes the compression after the shared stuff has been initialized. Called once.

Overrides:

initAfterCompression in class ProtobufLogReader

Parameters:

cellCodecClsName - class name of cell Codec

Throws:

IOException