Skip to content

Commit 79af0a5

Browse files
Update release/nightly_tests/dataset/tpch/tpch_q3.py
Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> Signed-off-by: ZTE Ray <dai.ping88@zte.com.cn>
1 parent bf0c428 commit 79af0a5

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

release/nightly_tests/dataset/tpch/tpch_q3.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,15 @@ def benchmark_fn():
2424
orders_filtered = orders.filter(expr=col("o_orderdate") < date)
2525

2626
# Join orders with customer
27+
orders_customer = orders_filtered.join(
28+
customer_filtered,
2729
orders_customer = orders_filtered.join(
2830
customer_filtered,
2931
join_type="inner",
3032
num_partitions=100,
31-
on=("o_custkey",),
32-
right_on=("c_custkey",),
33+
left_on="o_custkey",
34+
right_on="c_custkey",
3335
)
34-
35-
# Join with lineitem and filter by ship date
3636
lineitem_filtered = lineitem.filter(expr=col("l_shipdate") > date)
3737
ds = lineitem_filtered.join(
3838
orders_customer,

0 commit comments

Comments
 (0)