Struct LateDataClause 

pub struct LateDataClause {
    pub allowed_lateness: Option<Box<Expr>>,
    pub side_output: Option<String>,
}

Late data handling clause.

Controls what happens to events that arrive after their window has closed. This is the SQL AST representation of late data configuration. See laminar_core::operator::window::LateDataConfig for the runtime representation.

Fields

allowed_lateness: Option<Box<Expr>>

Allowed lateness duration (e.g., INTERVAL '1' HOUR)

side_output: Option<String>

Side output name for late events (e.g., late_events)

Implementations

impl LateDataClause

pub fn with_allowed_lateness(lateness: Expr) -> Self

Creates a clause with allowed lateness only.

pub fn with_side_output(lateness: Expr, side_output: String) -> Self

Creates a clause with both allowed lateness and side output.

pub fn side_output_only(side_output: String) -> Self

Creates a clause with side output only (uses default lateness).

pub fn to_allowed_lateness(&self) -> Result<Duration, ParseError>

Convert to allowed lateness Duration.

Errors

Returns ParseError::WindowError if the interval cannot be parsed.

pub fn has_side_output(&self) -> bool

Check if this clause has a side output configured.

pub fn get_side_output(&self) -> Option<&str>

Get the side output name, if configured.

Trait Implementations

impl Clone for LateDataClause

fn clone(&self) -> LateDataClause

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateDataClause

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

Formats the value using the given formatter.

impl Default for LateDataClause

fn default() -> LateDataClause

Returns the “default value” for a type.

impl PartialEq for LateDataClause

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for LateDataClause