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

Field Summary

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

byteStringUncompressor, cellDecoder, hasCompression, hasTagCompression, inputStream, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerWarnSize

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 org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrContext	readHeader(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, hasCompression, hasTagCompression, 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

Constructor Detail

SecureProtobufLogReader

public SecureProtobufLogReader()

Method Detail

getWriterClsNames

public List<String> getWriterClsNames()

Overrides:

getWriterClsNames in class ProtobufLogReader

readHeader

protected org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrContext readHeader(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