Trait parquet::compression::Codec

pub trait Codec {
    fn compress(
        &mut self, 
        input_buf: &[u8], 
        output_buf: &mut Vec<u8>
    ) -> Result<()>;
    fn decompress(
        &mut self, 
        input_buf: &[u8], 
        output_buf: &mut Vec<u8>
    ) -> Result<usize>;
}

Parquet compression codec interface.

Required methods

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>

Compresses data stored in slice input_buf and writes the compressed result to output_buf. Note that you’ll need to call clear() before reusing the same output_buf across different compress calls.

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

Decompresses data stored in slice input_buf and writes output to output_buf. Returns the total number of bytes written.

Implementors

impl Codec for BrotliCodec

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>

impl Codec for GZipCodec

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>

impl Codec for LZ4Codec

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>

impl Codec for SnappyCodec

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>

impl Codec for ZSTDCodec

fn decompress(
    &mut self,
    input_buf: &[u8],
    output_buf: &mut Vec<u8>
) -> Result<usize>

fn compress(&mut self, input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()>