Struct SourceDefinition 

pub struct SourceDefinition {
    pub name: String,
    pub watermark_column: Option<String>,
}

Source definition for channel derivation.

Represents a registered streaming source that can be consumed by MVs.

Fields

name: String

Source name (e.g., “trades”, “orders”).

watermark_column: Option<String>

Optional watermark column for event time processing.

Implementations

impl SourceDefinition

pub fn new(name: impl Into<String>) -> Self

Creates a new source definition.

pub fn with_watermark( name: impl Into<String>, watermark_column: impl Into<String>, ) -> Self

Creates a source definition with a watermark column.

Trait Implementations

impl Clone for SourceDefinition

fn clone(&self) -> SourceDefinition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceDefinition

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

Formats the value using the given formatter.