Skip to content

Commit 99aba0b

Browse files
committed
chore: final change
1 parent ef5aeb3 commit 99aba0b

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

examples/tpch/q16_part_supplier_relationship.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,9 @@
7373
p_sizes = F.make_array(*[lit(s).cast(pa.int32()) for s in SIZES_OF_INTEREST])
7474
df_part = df_part.filter(~F.array_position(p_sizes, col("p_size")).is_null())
7575

76-
df = df_part.join(df_partsupp, (["p_partkey"], ["ps_partkey"]), "inner")
76+
df = df_part.join(
77+
df_partsupp, left_on=["p_partkey"], right_on=["ps_partkey"], how="inner"
78+
)
7779

7880
df = df.select("p_brand", "p_type", "p_size", "ps_suppkey").distinct()
7981

0 commit comments

Comments
 (0)