Struct StreamSqlEngine 

pub struct StreamSqlEngine { /* private fields */ }

Stream SQL engine

Implementations

impl StreamSqlEngine

pub fn new(config: StreamSqlConfig) -> Self

Create a new Stream SQL engine

pub fn parse(&self, sql: &str) -> Result<SelectStatement>

Parse a SQL query

pub async fn execute(&self, sql: &str) -> Result<QueryResult>

Execute a SQL query

pub async fn register_stream(&self, metadata: StreamMetadata) -> Result<()>

Register a stream

pub async fn unregister_stream(&self, name: &str) -> Result<()>

Unregister a stream

pub async fn get_stream(&self, name: &str) -> Option<StreamMetadata>

Get stream metadata

pub async fn list_streams(&self) -> Vec<String>

List all streams

pub async fn get_stats(&self) -> StreamSqlStats

Get statistics

pub async fn clear_cache(&self)

Clear query cache

pub fn validate(&self, sql: &str) -> Result<()>

Validate a query without executing

pub fn explain(&self, sql: &str) -> Result<String>

Explain a query