Skip to main content

Module event_time

Module event_time 

Source
Expand description

Schema-aware event time extraction for compiled queries.

RowEventTimeExtractor reads the event timestamp directly from an EventRow field, avoiding the overhead of columnar extraction used by the batch-level EventTimeExtractor.

When no timestamp column is present (or the schema has no suitable field), the caller should fall back to using the row index as a monotonic surrogate.

Structsยง

EventTimeConfig
Configuration for event time extraction in compiled queries.
RowEventTimeExtractor
Extracts event timestamps from EventRow fields.