Struct LateDataClause 

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

SQL configuration for events that arrive after their window closes.

Fields

allowed_lateness: Option<Box<Expr>>

For example, INTERVAL '1' HOUR.

side_output: Option<String>

Destination for late events.

Implementations

impl LateDataClause

pub fn with_allowed_lateness(lateness: Expr) -> Self

Uses the given lateness without a side output.

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

Uses the given lateness and side output.

pub fn side_output_only(side_output: String) -> Self

Uses the default lateness with a side output.

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

Errors

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

pub fn has_side_output(&self) -> bool

Whether late events have a side-output destination.

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

The configured side-output destination.

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LateDataClause