org.apache.hadoop.hbase.regionserver.wal

Class SecureAsyncProtobufLogWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractProtobufLogWriter

org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter

org.apache.hadoop.hbase.regionserver.wal.SecureAsyncProtobufLogWriter

public class SecureAsyncProtobufLogWriter
extends AsyncProtobufLogWriter

Field Summary

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

cellEncoder, compressionContext, compressor, conf, length, trailer, trailerWarnSize, trailerWritten

Constructor Summary

Constructors

Constructor and Description
SecureAsyncProtobufLogWriter(EventLoopGroup eventLoopGroup, java.lang.Class<? extends Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
protected WALHeader	buildWALHeader(Configuration conf, WALHeader.Builder builder)
protected java.lang.String	getWriterClassName()
protected void	initAfterHeader(boolean doCompress)
protected void	setEncryptor(Encryptor encryptor)

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

append, close, getOutput, getOutputStreamForCellEncoder, initOutput, sync, writeMagicAndWALHeader, writeWALTrailerAndMagic

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

buildSecureWALHeader, getLength, init, secureInitAfterHeader, writeWALTrailer

Methods inherited from class java.lang.Object

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

Constructor Detail

SecureAsyncProtobufLogWriter

public SecureAsyncProtobufLogWriter(EventLoopGroup eventLoopGroup,
                                    java.lang.Class<? extends Channel> channelClass)

Method Detail

getWriterClassName

protected java.lang.String getWriterClassName()

Overrides:

getWriterClassName in class AsyncProtobufLogWriter

buildWALHeader

protected WALHeader buildWALHeader(Configuration conf,
                                   WALHeader.Builder builder)
                            throws java.io.IOException

Overrides:

buildWALHeader in class AbstractProtobufLogWriter

Throws:

java.io.IOException

setEncryptor

protected void setEncryptor(Encryptor encryptor)

Overrides:

setEncryptor in class AbstractProtobufLogWriter

initAfterHeader

protected void initAfterHeader(boolean doCompress)
                        throws java.io.IOException

Overrides:

initAfterHeader in class AbstractProtobufLogWriter

Throws:

java.io.IOException