Struct LateDataConfig 

pub struct LateDataConfig { /* private fields */ }

Configuration for late data handling.

Controls what happens to events that arrive after their window has closed (i.e., after watermark >= window_end + allowed_lateness).

This is particularly important for EmitStrategy::OnWindowClose, where late events are never re-incorporated into a closed window. The choice is between dropping them silently or routing them to a side output for separate processing (e.g., a late_events topic or table).

For EmitStrategy::Final, late events are always silently dropped regardless of this configuration.

Example

use laminar_core::operator::window::LateDataConfig;
use std::time::Duration;

// Route late events to a side output called "late_events"
let config = LateDataConfig::with_side_output("late_events".to_string());

// Drop late events (default behavior)
let config = LateDataConfig::drop();

Implementations

impl LateDataConfig

pub fn drop() -> Self

Creates a config that drops late events (default behavior).

pub fn with_side_output(name: String) -> Self

Creates a config that routes late events to a named side output.

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

Returns the side output name, if configured.

pub fn should_drop(&self) -> bool

Returns true if late events should be dropped.

Trait Implementations

impl Clone for LateDataConfig

fn clone(&self) -> LateDataConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LateDataConfig

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

Formats the value using the given formatter.

impl Default for LateDataConfig

fn default() -> LateDataConfig

Returns the “default value” for a type.

impl PartialEq for LateDataConfig

fn eq(&self, other: &LateDataConfig) -> 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 Eq for LateDataConfig

impl StructuralPartialEq for LateDataConfig