Struct EventTimeExtractor 

pub struct EventTimeExtractor { /* private fields */ }

Extracts event timestamps from Arrow RecordBatch columns.

Supports multiple timestamp formats and extraction modes for multi-row batches. Uses internal caching for column index lookup to optimize repeated extractions.

Implementations

impl EventTimeExtractor

pub fn from_column(name: &str, format: TimestampFormat) -> Self

Creates an extractor that looks up a column by name.

The column index is cached after the first extraction for efficiency.

pub fn from_index(index: usize, format: TimestampFormat) -> Self

Creates an extractor that uses a column by index.

This is the most efficient option as no lookup is required.

pub fn with_mode(self, mode: ExtractionMode) -> Self

Sets the extraction mode for multi-row batches.

pub fn format(&self) -> TimestampFormat

Gets the configured format.

pub fn mode(&self) -> ExtractionMode

Gets the configured mode.

pub fn validate_schema(&self, schema: &Schema) -> Result<(), EventTimeError>

Validates that the schema contains a compatible timestamp column.

Errors

Returns an error if the column is not found or has an incompatible type.

pub fn extract(&mut self, batch: &RecordBatch) -> Result<i64, EventTimeError>

Extracts the event timestamp from a batch.

Returns the timestamp in milliseconds since Unix epoch.

Errors

Returns an error if:

• The batch is empty
• The column is not found
• The column type is incompatible with the format
• The timestamp value is null
• The timestamp cannot be parsed

Trait Implementations

impl Debug for EventTimeExtractor

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

Formats the value using the given formatter.