@InterfaceAudience.LimitedPrivate(value="Configuration") public class SecureProtobufLogWriter extends ProtobufLogWriter
cellEncoder, compressor, output
compressionContext, conf
Constructor and Description |
---|
SecureProtobufLogWriter() |
Modifier and Type | Method and Description |
---|---|
protected WALProtos.WALHeader |
buildWALHeader(Configuration conf,
WALProtos.WALHeader.Builder builder) |
protected void |
initAfterHeader(boolean doCompress) |
append, close, getCodec, getLength, getStream, init, sync
initializeCompressionContext
protected WALProtos.WALHeader buildWALHeader(Configuration conf, WALProtos.WALHeader.Builder builder) throws java.io.IOException
buildWALHeader
in class ProtobufLogWriter
java.io.IOException
protected void initAfterHeader(boolean doCompress) throws java.io.IOException
initAfterHeader
in class ProtobufLogWriter
java.io.IOException