Skip to content

Commit ca21e67

Browse files
committed
make backToBackMap of DatasetBenchmark fair
In the original implementation, DataFrame version processes less work than RDD and Dataset versions.
1 parent 6759210 commit ca21e67

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DatasetBenchmark.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ object DatasetBenchmark {
5353
var res = df
5454
var i = 0
5555
while (i < numChains) {
56-
res = res.select($"l" + 1 as "l")
56+
res = res.select($"l" + 1 as "l", $"s")
5757
i += 1
5858
}
5959
res.queryExecution.toRdd.foreach(_ => Unit)

0 commit comments

Comments
 (0)