File tree Expand file tree Collapse file tree 3 files changed +18
-4
lines changed Expand file tree Collapse file tree 3 files changed +18
-4
lines changed Original file line number Diff line number Diff line change 11import duckdb
22
33from queries .duckdb import utils
4+ from settings import Settings
5+
6+ settings = Settings ()
47
58Q_NUM = 11
69
@@ -9,6 +12,8 @@ def q() -> None:
912 supplier_ds = utils .get_supplier_ds ()
1013 part_supp_ds = utils .get_part_supp_ds ()
1114 nation_ds = utils .get_nation_ds ()
15+ scale_factor = settings .scale_factor
16+ fraction = 0.0001 / scale_factor
1217
1318 query_str = f"""
1419 select
@@ -26,7 +31,7 @@ def q() -> None:
2631 ps_partkey having
2732 sum(ps_supplycost * ps_availqty) > (
2833 select
29- sum(ps_supplycost * ps_availqty) * 0.0001
34+ sum(ps_supplycost * ps_availqty) * { fraction }
3035 from
3136 { part_supp_ds } ,
3237 { supplier_ds } ,
Original file line number Diff line number Diff line change 33import polars as pl
44
55from queries .polars import utils
6+ from settings import Settings
7+
8+ settings = Settings ()
69
710Q_NUM = 11
811
2326 assert supplier is not None
2427
2528 var1 = "GERMANY"
26- var2 = 0.0001
29+ var2 = 0.0001 / settings . scale_factor
2730
2831 q1 = (
2932 partsupp .join (supplier , left_on = "ps_suppkey" , right_on = "s_suppkey" )
Original file line number Diff line number Diff line change 11from queries .pyspark import utils
2+ from settings import Settings
3+
4+ settings = Settings ()
25
36Q_NUM = 11
47
58
69def q () -> None :
7- query_str = """
10+ scale_factor = settings .scale_factor
11+ fraction = 0.0001 / scale_factor
12+
13+ query_str = f"""
814 select
915 ps_partkey,
1016 round(sum(ps_supplycost * ps_availqty), 2) as value
@@ -20,7 +26,7 @@ def q() -> None:
2026 ps_partkey having
2127 sum(ps_supplycost * ps_availqty) > (
2228 select
23- sum(ps_supplycost * ps_availqty) * 0.0001
29+ sum(ps_supplycost * ps_availqty) * { fraction }
2430 from
2531 partsupp,
2632 supplier,
You can’t perform that action at this time.
0 commit comments