public class SecureWALCellCodec extends WALCellCodec
WALCellCodec.ByteStringCompressor, WALCellCodec.ByteStringUncompressor, WALCellCodec.EnsureKvEncodercompression, 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, getWALCellCodecClasspublic 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 WALCellCodecpublic Encoder getEncoder(java.io.OutputStream os)
getEncoder in class WALCellCodecpublic static WALCellCodec getCodec(Configuration conf, Encryptor encryptor)
public static WALCellCodec getCodec(Configuration conf, Decryptor decryptor)