Last updated 1 year ago
res = pl.SQLContext(frame=df).execute( """ with cte as ( SELECT customer_id, primary_term, final_term from frame where primary_term > final_term limit 100 ) select * from cte order by primary_term desc limit 10 """ ) res.collect()
https://github.com/gautamnaik1994/2023-Pycon-Polars