improve_benchmark

B Vadlamani · B Vadlamani · commit 1027c8537fc7 · 2026-01-02T19:36:54.000-08:00
diff --git a/spark/src/test/scala/org/apache/spark/sql/benchmark/CometBenchmarkBase.scala b/spark/src/test/scala/org/apache/spark/sql/benchmark/CometBenchmarkBase.scala
@@ -292,7 +292,7 @@ trait CometBenchmarkBase extends SqlBasedBenchmark {
     val div = if (useDictionary) 5 else maxValue
     spark
       .range(values)
-      .map(i => i % div)
+      .map(_ % div)
       .select((($"value" - 500) / 100.0) cast decimal as Symbol("dec"))
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -292,7 +292,7 @@ trait CometBenchmarkBase extends SqlBasedBenchmark {`
`292`	`292`	`val div = if (useDictionary) 5 else maxValue`
`293`	`293`	`spark`
`294`	`294`	`.range(values)`
`295`		`- .map(i => i % div)`
	`295`	`+ .map(_ % div)`
`296`	`296`	`.select((($"value" - 500) / 100.0) cast decimal as Symbol("dec"))`
`297`	`297`	`}`
`298`	`298`	`}`