Struct DeltaSinkConfig 

pub struct DeltaSinkConfig {
    pub connection: DeltaConnection,
    pub create_if_not_missing: bool,
    pub partition_by: Vec<String>,
    pub schema_sample_size: usize,
    pub batch_size: usize,
    pub target_file_size: Option<usize>,
}

Available on crate feature sink-delta only.

Configuration for the Delta Lake sink connector (append-only in v1).

The table_uri / credentials / storage_options keys are flattened in from the shared DeltaConnection. On first write the sink opens the table (creating it from the inferred schema when create_if_not_missing), then appends one Delta commit per flush().

Fields

connection: DeltaConnection

Table location + object-store credentials.

create_if_not_missing: bool

Create the table (and its schema, from the inferred record shape) on the first write when it does not already exist. When false, an absent table fails the first write with a typed error.

partition_by: Vec<String>

Partition columns, applied only when the table is created. Ignored when appending to an existing table (its stored partitioning is used).

schema_sample_size: usize

Records sampled to infer the Arrow/Delta schema when creating the table.

batch_size: usize

Re-chunk size for Sink::write_batch. Incoming pages larger than this are sliced into batch_size-row Arrow batches before writing. 0 writes each page through as one batch.

target_file_size: Option<usize>

Optional target data-file size (bytes) hint for the writer’s rollover. Advisory — delta-rs rolls files at buffer boundaries near this size.

Implementations

impl DeltaSinkConfig

pub fn new(table_uri: impl Into<String>) -> DeltaSinkConfig

Build a sink config for table_uri with defaults.

pub fn validate(&self) -> Result<(), String>

Validate the config; returns a human-readable error string if invalid.

pub fn effective_sample_size(&self) -> usize

Effective schema sample size (never zero after validation).

Trait Implementations

impl Clone for DeltaSinkConfig

fn clone(&self) -> DeltaSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaSinkConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DeltaSinkConfig

fn deserialize<__D>( __deserializer: __D, ) -> Result<DeltaSinkConfig, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for DeltaSinkConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for DeltaSinkConfig

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.