Struct Event 

pub struct Event {
    pub timestamp: i64,
    pub data: Arc<RecordBatch>,
}

An event flowing through the system

Fields

timestamp: i64

Timestamp of the event

data: Arc<RecordBatch>

Event payload as Arrow RecordBatch wrapped in Arc for zero-copy multicast.

Cloning an Event increments the Arc reference count (~2ns, O(1)) instead of copying all column Arc pointers (O(columns)).

Implementations

impl Event

pub fn new(timestamp: i64, data: RecordBatch) -> Self

Create a new event, wrapping the batch in Arc for zero-copy sharing.

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.