Struct SnapshotTransforms 

pub struct SnapshotTransforms {
    pub pipeline: Pipeline,
    pub apply_opts: ApplyOpts,
}

Transform pipeline + apply options for interleaved snapshot sink writes.

Default is an identity pipeline with batch_size = 1 (no transform stage dispatch; matches pre-transform behavior).

Fields

pipeline: Pipeline

apply_opts: ApplyOpts

Implementations

impl SnapshotTransforms

pub fn identity() -> Self

Empty pipeline, per-row apply cadence.

pub fn from_refs(pipeline: &Pipeline, apply_opts: &ApplyOpts) -> Self

Borrowed view used by the runner.

Trait Implementations

impl Clone for SnapshotTransforms

fn clone(&self) -> SnapshotTransforms

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SnapshotTransforms

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

Formats the value using the given formatter.

impl Default for SnapshotTransforms

fn default() -> Self

Returns the “default value” for a type.