Struct CSPARQLWindow 

pub struct CSPARQLWindow {
    pub name: String,
    pub width: i64,
    pub slide: i64,
    pub time: i64,
    pub t0: i64,
    pub active_windows: HashMap<WindowInstance, QuadContainer>,
    pub report: ReportStrategy,
    pub tick: Tick,
    pub debug_mode: bool,
    /* private fields */
}

CSPARQL Window implementation

Fields

name: String

width: i64

slide: i64

time: i64

t0: i64

active_windows: HashMap<WindowInstance, QuadContainer>

report: ReportStrategy

tick: Tick

debug_mode: bool

Implementations

impl CSPARQLWindow

pub fn new( name: String, width: i64, slide: i64, report: ReportStrategy, tick: Tick, start_time: i64, ) -> Self

pub fn get_content(&self, timestamp: i64) -> Option<&QuadContainer>

Get window content at a specific timestamp Returns the window with the smallest close time that contains the timestamp

pub fn add(&mut self, quad: Quad, timestamp: i64)

Add a quad to the window at the given timestamp

pub fn scope(&mut self, t_e: i64)

Calculate and create windows based on the event time

pub fn subscribe<F>(&mut self, stream_type: StreamType, callback: F)

where F: Fn(QuadContainer) + Send + Sync + 'static,

Subscribe a callback to window emissions

pub fn get_content_from_window(&self, timestamp: i64) -> Option<&QuadContainer>

Get content from window at specific timestamp (alternative method name for compatibility)

pub fn get_active_window_count(&self) -> usize

Get the current number of active windows

pub fn get_active_window_ranges(&self) -> Vec<(i64, i64)>

Get the timestamp range of active windows

pub fn set_debug_mode(&mut self, enabled: bool)

Enable or disable debug mode for verbose logging