Struct CompressionConfig 

pub struct CompressionConfig { /* private fields */ }

Compression configuration for Parquet file writing.

Controls which compression algorithm is used and its level (for algorithms that support configurable compression levels).

Examples

use dbx_core::storage::compression::{CompressionConfig, CompressionAlgorithm};

// Default (Snappy)
let config = CompressionConfig::default();

// ZSTD with level 3 (balanced)
let config = CompressionConfig::new(CompressionAlgorithm::Zstd).with_level(3);

// Convert to Parquet compression setting
let parquet_compression = config.to_parquet_compression();

Implementations

impl CompressionConfig

pub fn new(algorithm: CompressionAlgorithm) -> Self

Create a new compression config with the specified algorithm.

pub fn with_level(self, level: u32) -> Self

Set the compression level (for ZSTD and Brotli only).

Levels are clamped to valid ranges:

• ZSTD: 1-22
• Brotli: 0-11
• Others: ignored

pub fn algorithm(&self) -> CompressionAlgorithm

Get the configured algorithm.

pub fn level(&self) -> Option<u32>

Get the configured level (if any).

pub fn to_parquet_compression(&self) -> Compression

Convert to Parquet’s Compression enum for use in WriterProperties.

pub fn none() -> Self

Preset: No compression (fastest I/O, largest files).

pub fn snappy() -> Self

Preset: Snappy (default — balanced speed and compression).

pub fn lz4() -> Self

Preset: LZ4 (ultra-fast, similar ratio to Snappy).

pub fn zstd() -> Self

Preset: ZSTD with default level (excellent ratio).

pub fn zstd_level(level: u32) -> Self

Preset: ZSTD with specified compression level (1-22).

pub fn brotli() -> Self

Preset: Brotli with default level (maximum ratio).

pub fn brotli_level(level: u32) -> Self

Preset: Brotli with specified compression level (0-11).

Trait Implementations

impl Clone for CompressionConfig

fn clone(&self) -> CompressionConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for CompressionConfig

impl Debug for CompressionConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CompressionConfig

fn default() -> Self

Default compression: Snappy (best general-purpose balance).

impl Eq for CompressionConfig

impl PartialEq for CompressionConfig

fn eq(&self, other: &CompressionConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for CompressionConfig