Skip to main content

validate_no_streaming_subqueries

Function validate_no_streaming_subqueries 

Source
pub fn validate_no_streaming_subqueries(
    sql: &str,
    streaming_tables: &HashSet<String>,
) -> SqlResult<()>
Expand description

Validate that sql contains no subqueries that reference a streaming table.

Returns Ok(()) when either:

  • No subqueries are present, or
  • No subquery body references a name in streaming_tables.

Returns Err when a subquery body contains a streaming table name (case- insensitive), because DataFusion’s decorrelation rules do not handle unbounded inputs.