deltalake-core 0.32.0

Native Delta Lake implementation in Rust
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

use parquet::basic::Compression;
use parquet::file::properties::WriterProperties;

pub(crate) fn default_writer_properties(compression: Compression) -> WriterProperties {
    WriterProperties::builder()
        .set_created_by(format!("delta-rs version {}", crate::crate_version()))
        .set_compression(compression)
        .build()
}

#[cfg(test)]
mod tests {
    use super::*;
    use parquet::schema::types::ColumnPath;

    #[test]
    fn default_writer_properties_sets_created_by_and_compression() {
        let writer_properties = default_writer_properties(Compression::SNAPPY);

        assert_eq!(
            writer_properties.created_by(),
            format!("delta-rs version {}", crate::crate_version())
        );
        assert_eq!(
            writer_properties.compression(&ColumnPath::from("id")),
            Compression::SNAPPY
        );
    }
}