public class SecureAsyncProtobufLogWriter extends AsyncProtobufLogWriter
cellEncoder, compressionContext, compressor, conf, length, trailer, trailerWarnSize, trailerWritten
Constructor and Description |
---|
SecureAsyncProtobufLogWriter(EventLoopGroup eventLoopGroup,
java.lang.Class<? extends Channel> channelClass) |
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) |
append, close, getOutput, getOutputStreamForCellEncoder, initOutput, sync, writeMagicAndWALHeader, writeWALTrailerAndMagic
buildSecureWALHeader, getLength, init, secureInitAfterHeader, writeWALTrailer
public SecureAsyncProtobufLogWriter(EventLoopGroup eventLoopGroup, java.lang.Class<? extends Channel> channelClass)
protected java.lang.String getWriterClassName()
getWriterClassName
in class AsyncProtobufLogWriter
protected WALHeader buildWALHeader(Configuration conf, WALHeader.Builder builder) throws java.io.IOException
buildWALHeader
in class AbstractProtobufLogWriter
java.io.IOException
protected void setEncryptor(Encryptor encryptor)
setEncryptor
in class AbstractProtobufLogWriter
protected void initAfterHeader(boolean doCompress) throws java.io.IOException
initAfterHeader
in class AbstractProtobufLogWriter
java.io.IOException