Struct ProcessingTimeGenerator 

pub struct ProcessingTimeGenerator { /* private fields */ }

Processing-time watermark generator.

Ignores event timestamps entirely and advances the watermark based on wall-clock time. Use with PROCTIME() sources where events are processed in arrival order without event-time semantics.

• on_event returns None (event timestamps are ignored)
• on_periodic returns Some(Watermark::new(now_millis()))

Example

use laminar_core::time::{ProcessingTimeGenerator, WatermarkGenerator};

let mut gen = ProcessingTimeGenerator::new();
// on_event ignores the timestamp
assert_eq!(gen.on_event(1000), None);
// on_periodic returns wall-clock time
let wm = gen.on_periodic();
assert!(wm.is_some());

Implementations

impl ProcessingTimeGenerator

pub fn new() -> Self

Creates a new processing-time watermark generator.

Trait Implementations

impl Default for ProcessingTimeGenerator

fn default() -> Self

Returns the “default value” for a type.

impl WatermarkGenerator for ProcessingTimeGenerator

fn on_event(&mut self, _timestamp: i64) -> Option<Watermark>

Process an event timestamp and potentially emit a new watermark.

fn on_periodic(&mut self) -> Option<Watermark>

Called periodically to emit watermarks based on wall-clock time.

fn current_watermark(&self) -> i64

Returns the current watermark value without advancing it.

fn advance_watermark(&mut self, timestamp: i64) -> Option<Watermark>

Advances the watermark to at least the given timestamp from an external source.

fn is_processing_time(&self) -> bool

Whether the watermark is processing-time based (wall clock), rather than derived from the event-time column. Such a watermark lives in a different time domain than the event timestamps, so comparing the two to drop “late” rows would discard every event — callers skip source-side late-filtering when this is true. Defaults to false (event-time generators).