Skip to main content

EventTimeExtractor

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

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§