Struct StreamingPlanner 

pub struct StreamingPlanner { /* private fields */ }

Streaming query planner

Implementations

impl StreamingPlanner

pub fn new() -> Self

Creates a new streaming planner

pub fn plan( &mut self, statement: &StreamingStatement, ) -> Result<StreamingPlan, PlanningError>

Plans a streaming statement.

Errors

Returns PlanningError if the statement cannot be planned.

pub fn get_source(&self, name: &str) -> Option<&SourceInfo>

Gets a registered source by name.

pub fn get_sink(&self, name: &str) -> Option<&SinkInfo>

Gets a registered sink by name.

pub fn list_sources(&self) -> Vec<&SourceInfo>

Lists all registered sources.

pub fn list_sinks(&self) -> Vec<&SinkInfo>

Lists all registered sinks.

pub async fn to_logical_plan( &self, plan: &QueryPlan, ctx: &SessionContext, ) -> Result<LogicalPlan, PlanningError>

Creates a DataFusion logical plan from a query plan.

Converts the query plan’s SQL statement into a DataFusion LogicalPlan using the session context’s state. Window UDFs (TUMBLE, HOP, SESSION) must be registered on the context via register_streaming_functions for windowed queries to resolve correctly.

Arguments

• plan - The streaming query plan containing the SQL statement
• ctx - DataFusion session context with registered UDFs

Errors

Returns PlanningError if DataFusion cannot create the logical plan.

Trait Implementations

impl Default for StreamingPlanner

fn default() -> Self

Returns the “default value” for a type.