EventTimeExtractor

llm_optimizer_processor::core

Trait EventTimeExtractor 

Source 
pub trait EventTimeExtractor<T> {
    // Required method
    fn extract_event_time(&self, event: &T) -> DateTime<Utc>;
}
Expand description

Trait for extracting event time from events

Implement this trait to define how to extract the timestamp from your event type. This is used for event time semantics in stream processing.

Required Methods§

Source

fn extract_event_time(&self, event: &T) -> DateTime<Utc>

Extract the event timestamp from the event

Implementors§