Struct StreamRunner 

pub struct StreamRunner {
    pub def: StreamDef,
    /* private fields */
}

Stream runner that processes events through optional windowing.

Fields

def: StreamDef

Implementations

impl StreamRunner

pub fn new(def: StreamDef) -> Self

pub fn process_event(&mut self, event: StreamEvent) -> Vec<Vec<WindowEvent>>

Process a single event. Returns any window outputs.

pub fn flush(&mut self) -> Option<Vec<WindowEvent>>

Force-flush any remaining window state.

pub fn events_processed(&self) -> u64

Number of events processed so far.

pub fn has_window(&self) -> bool

Whether this stream has windowing enabled.