This is an automated email from the ASF dual-hosted git repository.
comphead pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 0ba787f35 chore: `tpcbench` output `explain` just once and formatted
(#2679)
0ba787f35 is described below
commit 0ba787f35a3646566ca1c00857cf7a83194183b8
Author: Oleks V <[email protected]>
AuthorDate: Mon Nov 3 13:10:54 2025 -0800
chore: `tpcbench` output `explain` just once and formatted (#2679)
---
dev/benchmarks/tpcbench.py | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/dev/benchmarks/tpcbench.py b/dev/benchmarks/tpcbench.py
index 0a91bf033..75944883d 100644
--- a/dev/benchmarks/tpcbench.py
+++ b/dev/benchmarks/tpcbench.py
@@ -104,7 +104,7 @@ def main(benchmark: str, data_path: str, query_path: str,
iterations: int, outpu
if len(sql) > 0:
print(f"Executing: {sql}")
df = spark.sql(sql)
- df.explain()
+ df.explain("formatted")
if write_path is not None:
# skip results with empty schema
@@ -123,8 +123,6 @@ def main(benchmark: str, data_path: str, query_path: str,
iterations: int, outpu
else:
rows = df.collect()
print(f"Query {query} returned {len(rows)} rows")
- df.explain()
-
end_time = time.time()
print(f"Query {query} took {end_time - start_time} seconds")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
