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

All Implemented Interfaces:

Closeable, AutoCloseable, AsyncFSWALProvider.AsyncWriter, WALProvider.AsyncWriter, WALProvider.WriterBase

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class SecureAsyncProtobufLogWriter
extends AsyncProtobufLogWriter

Field Summary

Fields

Modifier and Type	Field and Description
private Encryptor	encryptor

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(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader	buildWALHeader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader.Builder builder)
protected 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, setWALTrailer, writeWALTrailer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.wal.AsyncFSWALProvider.AsyncWriter

init

Methods inherited from interface org.apache.hadoop.hbase.wal.WALProvider.WriterBase

getLength

Field Detail

encryptor

private Encryptor encryptor

Constructor Detail

SecureAsyncProtobufLogWriter

public SecureAsyncProtobufLogWriter(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                                    Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Detail

getWriterClassName

protected String getWriterClassName()

Overrides:

getWriterClassName in class AsyncProtobufLogWriter

buildWALHeader

protected org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader buildWALHeader(org.apache.hadoop.conf.Configuration conf,
                                                                                               org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader.Builder builder)
                                                                                        throws IOException

Overrides:

buildWALHeader in class AbstractProtobufLogWriter

Throws:

IOException

setEncryptor

protected void setEncryptor(Encryptor encryptor)

Overrides:

setEncryptor in class AbstractProtobufLogWriter

initAfterHeader

protected void initAfterHeader(boolean doCompress)
                        throws IOException

Overrides:

initAfterHeader in class AbstractProtobufLogWriter

Throws:

IOException