Struct SourceTuning 

pub struct SourceTuning {
    pub batch_size: usize,
    pub batch_size_memory_mb: Option<usize>,
    pub throttle_ms: u64,
    pub statement_timeout_s: u64,
    pub max_retries: u32,
    pub retry_backoff_ms: u64,
    pub lock_timeout_s: u64,
    pub memory_threshold_mb: usize,
    /* private fields */
}

Fields

batch_size: usize

batch_size_memory_mb: Option<usize>

throttle_ms: u64

statement_timeout_s: u64

max_retries: u32

retry_backoff_ms: u64

lock_timeout_s: u64

memory_threshold_mb: usize

Implementations

impl SourceTuning

pub fn from_config(config: Option<&TuningConfig>) -> Self

pub fn profile_name(&self) -> &'static str

impl SourceTuning

pub fn effective_batch_size(&self, schema: Option<&SchemaRef>) -> usize

If batch_size_memory_mb is set, compute and return an adjusted batch_size from the schema; otherwise return the configured batch_size.

Trait Implementations

impl Clone for SourceTuning

fn clone(&self) -> SourceTuning

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceTuning

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

Formats the value using the given formatter.

impl Display for SourceTuning

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

Formats the value using the given formatter.