public class SecureWALCellCodec extends WALCellCodec
WALCellCodec.ByteStringCompressor, WALCellCodec.ByteStringUncompressor, WALCellCodec.EnsureKvEncoder
compression, statelessUncompressor, WAL_CELL_CODEC_CLASS_KEY
Constructor and Description |
---|
SecureWALCellCodec(Configuration conf,
CompressionContext compression) |
SecureWALCellCodec(Configuration conf,
Decryptor decryptor) |
SecureWALCellCodec(Configuration conf,
Encryptor encryptor) |
Modifier and Type | Method and Description |
---|---|
static WALCellCodec |
getCodec(Configuration conf,
Decryptor decryptor) |
static WALCellCodec |
getCodec(Configuration conf,
Encryptor encryptor) |
Decoder |
getDecoder(java.io.InputStream is) |
Encoder |
getEncoder(java.io.OutputStream os) |
create, create, getByteStringCompressor, getByteStringUncompressor, getWALCellCodecClass
public SecureWALCellCodec(Configuration conf, CompressionContext compression)
public SecureWALCellCodec(Configuration conf, Encryptor encryptor)
public SecureWALCellCodec(Configuration conf, Decryptor decryptor)
public Decoder getDecoder(java.io.InputStream is)
getDecoder
in class WALCellCodec
public Encoder getEncoder(java.io.OutputStream os)
getEncoder
in class WALCellCodec
public static WALCellCodec getCodec(Configuration conf, Encryptor encryptor)
public static WALCellCodec getCodec(Configuration conf, Decryptor decryptor)