You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by ag...@apache.org on 2024/12/07 18:40:46 UTC
(datafusion-comet) branch main updated: Enable more scenarios in CometExecBenchmark. (#1151)
This is an automated email from the ASF dual-hosted git repository.
agrove 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 21503ca2 Enable more scenarios in CometExecBenchmark. (#1151)
21503ca2 is described below
commit 21503ca26f4d1a7b1b0eb1583158bbcddd695909
Author: Matt Butrovich <mb...@users.noreply.github.com>
AuthorDate: Sat Dec 7 13:40:43 2024 -0500
Enable more scenarios in CometExecBenchmark. (#1151)
---
.../spark/sql/benchmark/CometExecBenchmark.scala | 34 +++++++++++-----------
1 file changed, 17 insertions(+), 17 deletions(-)
diff --git a/spark/src/test/scala/org/apache/spark/sql/benchmark/CometExecBenchmark.scala b/spark/src/test/scala/org/apache/spark/sql/benchmark/CometExecBenchmark.scala
index 3dd930f6..3ee37bd6 100644
--- a/spark/src/test/scala/org/apache/spark/sql/benchmark/CometExecBenchmark.scala
+++ b/spark/src/test/scala/org/apache/spark/sql/benchmark/CometExecBenchmark.scala
@@ -274,23 +274,23 @@ object CometExecBenchmark extends CometBenchmarkBase {
}
override def runCometBenchmark(mainArgs: Array[String]): Unit = {
-// runBenchmarkWithTable("Subquery", 1024 * 1024 * 10) { v =>
-// subqueryExecBenchmark(v)
-// }
-//
-// runBenchmarkWithTable("Expand", 1024 * 1024 * 10) { v =>
-// expandExecBenchmark(v)
-// }
-//
-// runBenchmarkWithTable("Project + Filter", 1024 * 1024 * 10) { v =>
-// for (fractionOfZeros <- List(0.0, 0.50, 0.95)) {
-// numericFilterExecBenchmark(v, fractionOfZeros)
-// }
-// }
-//
-// runBenchmarkWithTable("Sort", 1024 * 1024 * 10) { v =>
-// sortExecBenchmark(v)
-// }
+ runBenchmarkWithTable("Subquery", 1024 * 1024 * 10) { v =>
+ subqueryExecBenchmark(v)
+ }
+
+ runBenchmarkWithTable("Expand", 1024 * 1024 * 10) { v =>
+ expandExecBenchmark(v)
+ }
+
+ runBenchmarkWithTable("Project + Filter", 1024 * 1024 * 10) { v =>
+ for (fractionOfZeros <- List(0.0, 0.50, 0.95)) {
+ numericFilterExecBenchmark(v, fractionOfZeros)
+ }
+ }
+
+ runBenchmarkWithTable("Sort", 1024 * 1024 * 10) { v =>
+ sortExecBenchmark(v)
+ }
runBenchmarkWithTable("BloomFilterAggregate", 1024 * 1024 * 10) { v =>
for (card <- List(100, 1024, 1024 * 1024)) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org