Struct RSPEngine 

pub struct RSPEngine { /* private fields */ }

The main RSP (RDF Stream Processing) Engine

Implementations

impl RSPEngine

pub fn new(query: String) -> Self

Create a new RSP Engine from an RSPQL query

pub fn initialize(&mut self) -> Result<(), String>

Initialize the engine by creating windows and streams

pub fn register( windows: HashMap<String, Arc<Mutex<CSPARQLWindow>>>, r2r: R2ROperator, window_defs: Vec<WindowDefinition>, ) -> Receiver<BindingWithTimestamp>

Register a callback for processing window content Returns a receiver for binding results

pub fn start_processing(&self) -> Receiver<BindingWithTimestamp>

Convenience method to register using the engine’s own data

pub fn get_stream(&self, stream_name: &str) -> Option<RDFStream>

Get a stream by name (returns a clone for easier usage)

pub fn add_static_data(&mut self, quad: Quad)

Add static data to the R2R operator

pub fn get_all_streams(&self) -> Vec<String>

Get all stream names

pub fn close_stream( &self, stream_uri: &str, final_timestamp: i64, ) -> Result<(), String>

Add a sentinel event to trigger closure of all open windows This should be called when the stream ends to emit final results

pub fn parsed_query(&self) -> &ParsedQuery

Get the parsed query

pub fn get_window(&self, window_name: &str) -> Option<Arc<Mutex<CSPARQLWindow>>>

Get a window by name