Use noop() in WideTableBenchmark

MaxGekk · MaxGekk · commit 6615d5a8f30c · 2020-01-02T18:06:05.000+05:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/WideTableBenchmark.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/WideTableBenchmark.scala
@@ -42,7 +42,7 @@ object WideTableBenchmark extends SqlBasedBenchmark {
       Seq("10", "100", "1024", "2048", "4096", "8192", "65536").foreach { n =>
         benchmark.addCase(s"split threshold $n", numIters = 5) { iter =>
           withSQLConf(SQLConf.CODEGEN_METHOD_SPLIT_THRESHOLD.key -> n) {
-            df.selectExpr(columns: _*).foreach(_ => ())
+            df.selectExpr(columns: _*).noop()
           }
         }
       }

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ object WideTableBenchmark extends SqlBasedBenchmark {`
`42`	`42`	`Seq("10", "100", "1024", "2048", "4096", "8192", "65536").foreach { n =>`
`43`	`43`	`benchmark.addCase(s"split threshold $n", numIters = 5) { iter =>`
`44`	`44`	`withSQLConf(SQLConf.CODEGEN_METHOD_SPLIT_THRESHOLD.key -> n) {`
`45`		`- df.selectExpr(columns: _*).foreach(_ => ())`
	`45`	`+ df.selectExpr(columns: _*).noop()`
`46`	`46`	`}`
`47`	`47`	`}`
`48`	`48`	`}`