Skip to main content

execute_sql

Function execute_sql 

Source
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.