Struct ParsedStreamFragment 

pub struct ParsedStreamFragment {
    pub window_kind: WindowKind,
    pub key_col: String,
    pub time_col: String,
    pub window_ms: u64,
    pub lag_ms: u64,
    pub slide_ms: Option<u64>,
    pub session_gap_ms: Option<u64>,
    pub ttl_ms: Option<u64>,
    pub agg: WindowAgg,
    pub source_id_column: Option<String>,
    pub source_watermark_lags: HashMap<String, u64>,
}

Parsed streaming window fragment (all window kinds).

Fields

window_kind: WindowKind

key_col: String

time_col: String

window_ms: u64

lag_ms: u64

slide_ms: Option<u64>

session_gap_ms: Option<u64>

ttl_ms: Option<u64>

agg: WindowAgg

source_id_column: Option<String>

Source-id column name for multi-source watermark tracking.

source_watermark_lags: HashMap<String, u64>

Per-source fixed watermark lags: source_id → lag_ms.

Trait Implementations

impl Clone for ParsedStreamFragment

fn clone(&self) -> ParsedStreamFragment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParsedStreamFragment

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

Formats the value using the given formatter.

impl Eq for ParsedStreamFragment

impl PartialEq for ParsedStreamFragment

fn eq(&self, other: &ParsedStreamFragment) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ParsedStreamFragment