Skip to content

Commit c60a44d

Browse files
committed
Manually bind references
1 parent 996332a commit c60a44d

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/SortSuite.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@
1717

1818
package org.apache.spark.sql.execution
1919

20-
import org.apache.spark.sql.catalyst.dsl.expressions._
21-
import org.apache.spark.sql.catalyst.expressions.{Ascending, SortOrder}
20+
import org.apache.spark.sql.catalyst.expressions.{BoundReference, Ascending, SortOrder}
21+
import org.apache.spark.sql.types.{IntegerType, StringType}
2222

2323
class SortSuite extends SparkPlanTest {
2424

@@ -31,8 +31,8 @@ class SortSuite extends SparkPlanTest {
3131
)
3232

3333
val sortOrder = Seq(
34-
SortOrder('_1, Ascending),
35-
SortOrder('_2, Ascending)
34+
SortOrder(BoundReference(0, StringType, nullable = false), Ascending),
35+
SortOrder(BoundReference(1, IntegerType, nullable = false), Ascending)
3636
)
3737

3838
checkAnswer(

sql/core/src/test/scala/org/apache/spark/sql/execution/SparkPlanTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ class SparkPlanTest extends SparkFunSuite {
6060
planFunction: SparkPlan => SparkPlan,
6161
expectedAnswer: Seq[A]): Unit = {
6262
val inputDf = TestSQLContext.createDataFrame(input)
63-
val expectedRows = expectedAnswer.map(t => Row.apply(t))
63+
val expectedRows = expectedAnswer.map(Row.fromTuple)
6464
SparkPlanTest.checkAnswer(inputDf, planFunction, expectedRows) match {
6565
case Some(errorMessage) => fail(errorMessage)
6666
case None =>

0 commit comments

Comments
 (0)