Struct WriterConnectConfig 

pub struct WriterConnectConfig {
    pub uri: String,
    pub catalog: Option<CatalogConnectConfig>,
    pub rotation_config: RotationConfig,
    pub flush_interval_ms: Option<u64>,
    pub record_filter: Option<WriterRecordFilter>,
    pub promotion_interval_ms: Option<u64>,
    pub promote_on_close: bool,
    pub delete_feather_after_promotion: bool,
    pub use_ts_event_for_ts_init: bool,
    pub params: Option<Params>,
}

Connection settings handed to writer factories.

Fields

uri: String

Local run-session directory the writer appends Feather files to.

catalog: Option<CatalogConnectConfig>

Catalog that receives promoted data; required by every backend except Feather.

rotation_config: RotationConfig

Rotation settings used by built-in streaming writer backends.

flush_interval_ms: Option<u64>

Optional automatic flush interval in milliseconds.

record_filter: Option<WriterRecordFilter>

Optional record-family and identifier filter.

promotion_interval_ms: Option<u64>

Interval in milliseconds for promoting sealed files into catalog.

promote_on_close: bool

Whether closing the writer promotes remaining files into catalog.

delete_feather_after_promotion: bool

Whether Feather files are deleted after a successful promotion.

use_ts_event_for_ts_init: bool

Whether promotion replaces ts_init with ts_event.

params: Option<Params>

Backend-specific writer parameters.

Implementations

impl WriterConnectConfig

pub fn new( uri: impl Into<String>, catalog: Option<CatalogConnectConfig>, ) -> Self

Creates a connect config for the given writer directory and promotion catalog.

pub fn required_catalog(&self, backend: &str) -> Result<&CatalogConnectConfig>

Returns the catalog that receives promoted data.

Errors

Returns an error if no catalog is configured. The error names backend.

Trait Implementations

impl Clone for WriterConnectConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterConnectConfig

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

Formats the value using the given formatter.