Struct ParquetStorageConfig 

pub struct ParquetStorageConfig {
    pub batch_size: usize,
    pub flush_timeout: Duration,
    pub compression: Compression,
}

Configuration for ParquetStorage batch processing

Fields

batch_size: usize

Batch size before automatic flush (default: 10,000)

flush_timeout: Duration

Timeout before flushing partial batch (default: 5 seconds)

compression: Compression

Compression codec for Parquet files

Implementations

impl ParquetStorageConfig

pub fn high_throughput() -> Self

High-throughput configuration optimized for large batch writes

pub fn low_latency() -> Self

Low-latency configuration for smaller, more frequent writes

Trait Implementations

impl Clone for ParquetStorageConfig

fn clone(&self) -> ParquetStorageConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParquetStorageConfig

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

Formats the value using the given formatter.

impl Default for ParquetStorageConfig

fn default() -> Self

Returns the “default value” for a type.