Expand description
E5.1 — Correlated subquery decorrelation: EXISTS/IN/scalar subquery analysis.
DataFusion 53 already handles subquery decorrelation for batch queries via
the DecorrelatePredicateSubquery optimizer rule. This module adds:
- AST-level detection of EXISTS/IN/NOT IN/scalar subquery patterns.
- Streaming guard: rejects correlated subqueries that reference a registered streaming table — DataFusion does not handle these.
- Kind classification so callers can adapt error messages and explain output.
Structs§
- Detected
Subquery - A subquery occurrence found in a SQL statement.
Enums§
- Subquery
Kind - Classification of a subquery occurrence detected in a SQL statement.
Functions§
- detect_
subqueries - Analyse
sqland return every subquery occurrence. - explain_
subqueries - Return a human-readable summary of subquery kinds found in
sql. - validate_
no_ streaming_ subqueries - Validate that
sqlcontains no subqueries that reference a streaming table.