pub fn execute_sql(
session: &SparkSession,
query: &str,
) -> Result<DataFrame, PolarsError>Expand description
Parse a SQL string and execute it using the session’s catalog. Supports: SELECT (columns or *), FROM single table or two-table JOIN, WHERE (basic predicates), GROUP BY + aggregates, ORDER BY, LIMIT.