@InterfaceAudience.LimitedPrivate(value="Configuration") public class SecureAsyncProtobufLogWriter extends AsyncProtobufLogWriter
Modifier and Type | Field and Description |
---|---|
private Encryptor |
encryptor |
cellEncoder, compressionContext, compressor, conf, length, trailer, trailerWarnSize, trailerWritten
Constructor and Description |
---|
SecureAsyncProtobufLogWriter(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass) |
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) |
append, close, closeOutputIfNecessary, getOutput, getOutputStreamForCellEncoder, getSyncedLength, initOutput, sync, writeMagicAndWALHeader, writeWALTrailerAndMagic
buildSecureWALHeader, getLength, init, secureInitAfterHeader, setWALTrailer, writeWALTrailer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
init
getLength
public SecureAsyncProtobufLogWriter(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
protected String getWriterClassName()
getWriterClassName
in class AsyncProtobufLogWriter
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
buildWALHeader
in class AbstractProtobufLogWriter
IOException
protected void setEncryptor(Encryptor encryptor)
setEncryptor
in class AbstractProtobufLogWriter
protected void initAfterHeader(boolean doCompress) throws IOException
initAfterHeader
in class AbstractProtobufLogWriter
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.