Struct RowEventTimeExtractor 

pub struct RowEventTimeExtractor { /* private fields */ }

Extracts event timestamps from EventRow fields.

Supports Int64 and TimestampMicros field types. Tracks the maximum observed timestamp and computes a watermark with a configurable delay.

Auto-Detection

When no explicit column is specified, from_schema scans the schema for:

1. A TimestampMicros field (first one found)
2. A field named ts, event_time, or timestamp (case-insensitive)

If neither heuristic matches, returns None — the caller should use a monotonic surrogate (row index).

Implementations

impl RowEventTimeExtractor

pub fn new(field_idx: usize, field_type: FieldType, delay: i64) -> Self

Creates an extractor for a known field index and type.

Panics

Debug-asserts that field_type is Int64 or TimestampMicros.

pub fn from_schema(schema: &RowSchema, config: &EventTimeConfig) -> Option<Self>

Attempts to create an extractor by scanning the schema.

Uses the following strategy:

1. If config.column is Some(name), look up that column exactly.
2. Otherwise, pick the first TimestampMicros field.
3. Otherwise, pick a field named ts, event_time, or timestamp.

Returns None if no suitable field is found.

pub fn extract(&mut self, row: &EventRow<'_>) -> i64

Extracts the event time from a row and updates the max timestamp.

Returns the raw timestamp value (microseconds or plain i64).

pub fn watermark(&self) -> i64

Returns the current watermark: max_timestamp - delay.

Returns i64::MIN if no timestamps have been observed.

pub fn max_timestamp(&self) -> i64

Returns the maximum observed timestamp.

pub fn field_idx(&self) -> usize

Returns the field index used for extraction.

pub fn field_type(&self) -> FieldType

Returns the field type used for extraction.

Trait Implementations

impl Debug for RowEventTimeExtractor

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

Formats the value using the given formatter.