File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ package org.apache.spark.sql
1919
2020import org .scalatest .Matchers ._
2121
22- import org .apache .spark .sql .execution .Project
22+ import org .apache .spark .sql .execution .{ Project , TungstenProject }
2323import org .apache .spark .sql .functions ._
2424import org .apache .spark .sql .types ._
2525
@@ -523,6 +523,7 @@ class ColumnExpressionSuite extends QueryTest {
523523 def checkNumProjects (df : DataFrame , expectedNumProjects : Int ): Unit = {
524524 val projects = df.queryExecution.executedPlan.collect {
525525 case project : Project => project
526+ case tungstenProject : TungstenProject => tungstenProject
526527 }
527528 assert(projects.size === expectedNumProjects)
528529 }
You can’t perform that action at this time.
0 commit comments