Skip to main content

Module temporal_probe

Module temporal_probe 

Source
Expand description

Temporal probe join configuration Configuration types for the temporal probe join operator.

A temporal probe join matches each left event against the right stream at multiple fixed time offsets. For each left row, it produces N output rows (one per offset) with the ASOF-matched right value at event_time + offset.

Structs§

TemporalProbeConfig
Configuration for the temporal probe join operator.

Enums§

ProbeOffsetSpec
Offset specification: either a uniform range or an explicit list.

Functions§

parse_interval_to_ms
Parse a duration string like 0s, 5s, 100ms, 1m, -5s into milliseconds.