oops

ion-elgreco · ion-elgreco · commit ef5aeb3e6335 · 2024-11-02T11:10:56.000+01:00
diff --git a/examples/tpch/q21_suppliers_kept_orders_waiting.py b/examples/tpch/q21_suppliers_kept_orders_waiting.py
@@ -102,7 +102,9 @@
 )
 
 # Join to the supplier of interest list for the nation of interest
-df = df.join(df_suppliers_of_interest, (["suppkey"], ["s_suppkey"]), "inner")
+df = df.join(
+    df_suppliers_of_interest, left_on=["suppkey"], right_on=["s_suppkey"], how="inner"
+)
 
 # Count how many orders that supplier is the only failed supplier for
 df = df.aggregate([col("s_name")], [F.count(col("o_orderkey")).alias("numwait")])

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,9 @@`
`102`	`102`	`)`
`103`	`103`
`104`	`104`	`# Join to the supplier of interest list for the nation of interest`
`105`		`-df = df.join(df_suppliers_of_interest, (["suppkey"], ["s_suppkey"]), "inner")`
	`105`	`+df = df.join(`
	`106`	`+ df_suppliers_of_interest, left_on=["suppkey"], right_on=["s_suppkey"], how="inner"`
	`107`	`+)`
`106`	`108`
`107`	`109`	`# Count how many orders that supplier is the only failed supplier for`
`108`	`110`	`df = df.aggregate([col("s_name")], [F.count(col("o_orderkey")).alias("numwait")])`