parquet-lite 0.2.0

A lightweight, pure-Rust alternative to the official Apache Parquet crate — minimal dependencies, small binary size, WASM-compatible
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use super::CompressionCodec;
use crate::types::{ParquetError, Result};

/// Snappy compression codec using the `snap` crate.
pub struct SnappyCodec;

#[allow(unused_variables)]
impl CompressionCodec for SnappyCodec {
    fn decompress(&self, data: &[u8], _uncompressed_size: usize) -> Result<Vec<u8>> {
        #[cfg(feature = "snappy")]
        {
            snap::raw::Decoder::new()
                .decompress_vec(data)
                .map_err(|e| ParquetError::DataError(format!("Snappy decompress error: {e}")))
        }
        #[cfg(not(feature = "snappy"))]
        {
            Err(ParquetError::UnsupportedCompression(
                "Snappy support not enabled".into(),
            ))
        }
    }

    fn compress(&self, data: &[u8]) -> Result<Vec<u8>> {
        #[cfg(feature = "snappy")]
        {
            snap::raw::Encoder::new()
                .compress_vec(data)
                .map_err(|e| ParquetError::DataError(format!("Snappy compress error: {e}")))
        }
        #[cfg(not(feature = "snappy"))]
        {
            Err(ParquetError::UnsupportedCompression(
                "Snappy support not enabled".into(),
            ))
        }
    }
}