Struct StreamingQuery 

pub struct StreamingQuery { /* private fields */ }

A running streaming query that connects compiled pipelines to Ring 1 via bridges.

StreamingQuery manages the lifecycle (start/pause/resume/stop), processes events through compiled or fallback pipelines, and produces Ring1Actions for downstream stateful operators.

Implementations

impl StreamingQuery

pub fn start(&mut self) -> Result<(), QueryError>

Transitions from QueryState::Ready to QueryState::Running.

Errors

Returns QueryError::InvalidState if not in Ready state.

pub fn pause(&mut self) -> Result<(), QueryError>

Transitions from QueryState::Running to QueryState::Paused.

Errors

Returns QueryError::InvalidState if not in Running state.

pub fn resume(&mut self) -> Result<(), QueryError>

Transitions from QueryState::Paused to QueryState::Running.

Errors

Returns QueryError::InvalidState if not in Paused state.

pub fn stop(&mut self) -> Result<(), QueryError>

Transitions to QueryState::Stopped from any non-terminal state.

Errors

Returns QueryError::InvalidState if already in Stopped state.

pub fn submit_row( &mut self, row: &EventRow<'_>, event_time: i64, key_hash: u64, ) -> Result<SubmitResult, QueryError>

Submits an event row for processing through all pipelines.

For compiled pipelines, the row is executed through the native function and the result is sent to the corresponding bridge. For fallback pipelines, the input row is sent directly (passthrough) for Ring 1 interpreted execution.

Errors

Returns QueryError::InvalidState if not in Running state. Returns QueryError::PipelineError if a compiled pipeline returns Error. Returns QueryError::Bridge if a bridge send fails.

pub fn advance_watermark(&self, timestamp: i64) -> Result<(), QueryError>

Sends a watermark advance through all bridges.

Errors

Returns QueryError::InvalidState if not in Running state. Returns QueryError::Bridge if any bridge send fails.

pub fn checkpoint(&self, epoch: u64) -> Result<(), QueryError>

Sends a checkpoint barrier through all bridges.

Errors

Returns QueryError::InvalidState if not in Running state. Returns QueryError::Bridge if any bridge send fails.

pub fn send_eof(&self) -> Result<(), QueryError>

Sends an end-of-stream marker through all bridges.

Errors

Returns QueryError::Bridge if any bridge send fails.

pub fn poll_ring1(&mut self) -> SmallVec<[Ring1Action; 4]>

Drains all consumers and returns concatenated Ring 1 actions.

pub fn check_latency_flush(&mut self) -> SmallVec<[Ring1Action; 4]>

Checks all consumers for latency-triggered flushes.

pub fn swap( &mut self, new: StreamingQuery, ) -> Result<StreamingQuery, QueryError>

Swaps this query’s pipelines, bridges, and consumers with those from new.

Both queries must have the same number of pipelines. The new query inherits the current Running or Paused state.

Errors

Returns QueryError::InvalidState if in Ready or Stopped state. Returns QueryError::IncompatibleSchemas if pipeline counts differ.

pub fn id(&self) -> QueryId

Returns the query identifier.

pub fn sql(&self) -> &str

Returns the SQL text for this query.

pub fn state(&self) -> QueryState

Returns the current lifecycle state.

pub fn metadata(&self) -> &QueryMetadata

Returns compilation metadata.

pub fn pipeline_count(&self) -> usize

Returns the number of pipelines in this query.

pub fn metrics(&self) -> QueryMetrics

Aggregates runtime metrics from all pipelines and bridges.

Trait Implementations

impl Debug for StreamingQuery

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

Formats the value using the given formatter.