@@ -20,7 +20,9 @@ def create_polars_lazyframe(test_data):
2020
2121
2222def analyze_pandas_dataframe (pandas_df ):
23- pandas_df .groupby (["region" , "product" , "sales_person" ])["sales_income" ].sum ()
23+ pandas_df .groupby (
24+ ["region" , "product" , "sales_person" ]
25+ )["sales_income" ].sum ()
2426
2527
2628def analyze_polars_dataframe (polars_df ):
@@ -38,13 +40,19 @@ def analyze_polars_lazyframe(polars_lf):
3840test_data = data_generation (int (sys .argv [1 ]))
3941
4042print (f"Pandas dataframe creation time for { int (sys .argv [1 ])} rows:" )
41- print (Timer (functools .partial (create_pandas_dataframe , test_data )).timeit (100 ))
43+ print (
44+ Timer (functools .partial (create_pandas_dataframe , test_data )).timeit (100 )
45+ )
4246print ()
4347print (f"Polars dataframe creation time for { int (sys .argv [1 ])} rows:" )
44- print (Timer (functools .partial (create_polars_dataframe , test_data )).timeit (100 ))
48+ print (
49+ Timer (functools .partial (create_polars_dataframe , test_data )).timeit (100 )
50+ )
4551print ()
4652print (f"Polars lazyframe creation time for { int (sys .argv [1 ])} rows:" )
47- print (Timer (functools .partial (create_polars_lazyframe , test_data )).timeit (100 ))
53+ print (
54+ Timer (functools .partial (create_polars_lazyframe , test_data )).timeit (100 )
55+ )
4856
4957print ()
5058
@@ -53,12 +61,18 @@ def analyze_polars_lazyframe(polars_lf):
5361polars_lf = create_polars_lazyframe (test_data )
5462
5563print (f"Pandas dataframe analysis time for { int (sys .argv [1 ])} rows:" )
56- print (Timer (functools .partial (analyze_pandas_dataframe , pandas_df )).timeit (100 ))
64+ print (
65+ Timer (functools .partial (analyze_pandas_dataframe , pandas_df )).timeit (100 )
66+ )
5767
5868print ()
5969print (f"Polars dataframe analysis time for { int (sys .argv [1 ])} rows:" )
60- print (Timer (functools .partial (analyze_polars_dataframe , polars_df )).timeit (100 ))
70+ print (
71+ Timer (functools .partial (analyze_polars_dataframe , polars_df )).timeit (100 )
72+ )
6173
6274print ()
6375print (f"Polars lazyframe analysis time for { int (sys .argv [1 ])} rows:" )
64- print (Timer (functools .partial (analyze_polars_lazyframe , polars_lf )).timeit (100 ))
76+ print (
77+ Timer (functools .partial (analyze_polars_lazyframe , polars_lf )).timeit (100 )
78+ )
0 commit comments