Module time 

Event time, watermarks, and timer management.

Structs

AscendingTimestampsGenerator

Watermark generator for strictly ascending timestamps.

BoundedOutOfOrdernessGenerator

Watermark generator with bounded out-of-orderness.

CastError

Error returned when a column isn’t a Timestamp(_) type or Arrow’s cast kernel fails.

EventTimeExtractor

Extracts event timestamps from Arrow RecordBatch columns.

PeriodicGenerator

Periodic watermark generator that emits at fixed wall-clock intervals.

ProcessingTimeGenerator

Processing-time watermark generator.

PunctuatedGenerator

Punctuated watermark generator that emits based on special events.

SourceProvidedGenerator

Watermark generator for sources with embedded watermarks.

TimerRegistration

A timer registration for delayed processing.

TimerService

Timer service for scheduling and managing timers.

Watermark

A watermark indicating event time progress.

WatermarkTracker

Tracks watermarks across multiple input sources.

Enums

EventTimeError

Errors that can occur during event time extraction.

ExtractionMode

Multi-row extraction strategy.

ThresholdOp

Direction of timestamp threshold comparison.

TimeError

Errors that can occur in time operations.

TimestampField

Column identifier for timestamp field.

Traits

WatermarkGenerator

Trait for generating watermarks from event timestamps.

Functions

cast_to_millis_array

Cast any Timestamp(_) array to TimestampMillisecondArray.

filter_batch_by_timestamp

Filter a RecordBatch by comparing a Timestamp(_) column against a millisecond threshold. Returns Ok(None) when no rows survive.

parse_duration_str

Parses a config duration string. Returns None on malformed input.

Type Aliases

FiredTimersVec

Collection type for fired timers.

TimerKey

Timer key type optimized for window IDs (16 bytes).