You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by co...@apache.org on 2025/11/03 21:10:58 UTC
(datafusion-comet) branch main updated: chore: `tpcbench` output `explain` just once and formatted (#2679)
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 <co...@users.noreply.github.com>
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: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org