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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
