From 996332ab0ff6432110f134efaf622d2fa10561b8 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Thu, 18 Jun 2015 10:36:34 -0700 Subject: [PATCH] Add types so that tests compile --- .../apache/spark/sql/execution/SortSuite.scala | 2 +- .../spark/sql/execution/SparkPlanTest.scala | 16 ++++++++-------- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/SortSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/SortSuite.scala index bd42917162bdd..a890904f90a85 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/SortSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/SortSuite.scala @@ -37,7 +37,7 @@ class SortSuite extends SparkPlanTest { checkAnswer( input, - child => new ExternalSort(sortOrder, global = false, child), + (child: SparkPlan) => new ExternalSort(sortOrder, global = false, child), input.sorted ) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkPlanTest.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkPlanTest.scala index 93165b17f5550..ed8c761b69093 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkPlanTest.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkPlanTest.scala @@ -26,16 +26,16 @@ import org.apache.spark.sql.{Row, DataFrame} import org.apache.spark.sql.catalyst.util._ /** - * Base class for writing tests for individual physical operators. For an example of how this class - * can be used, see [[SortSuite]]. + * Base class for writing tests for individual physical operators. For an example of how this + * class's test helper methods can be used, see [[SortSuite]]. */ class SparkPlanTest extends SparkFunSuite { /** * Runs the plan and makes sure the answer matches the expected result. * @param input the input data to be used. - * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate the - * physical operator that's being tested. + * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate + * the physical operator that's being tested. * @param expectedAnswer the expected result in a [[Seq]] of [[Row]]s. */ protected def checkAnswer( @@ -51,8 +51,8 @@ class SparkPlanTest extends SparkFunSuite { /** * Runs the plan and makes sure the answer matches the expected result. * @param input the input data to be used. - * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate the - * physical operator that's being tested. + * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate + * the physical operator that's being tested. * @param expectedAnswer the expected result in a [[Seq]] of [[Product]]s. */ protected def checkAnswer[A <: Product : TypeTag]( @@ -76,8 +76,8 @@ object SparkPlanTest { /** * Runs the plan and makes sure the answer matches the expected result. * @param input the input data to be used. - * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate the - * physical operator that's being tested. + * @param planFunction a function which accepts the input SparkPlan and uses it to instantiate + * the physical operator that's being tested. * @param expectedAnswer the expected result in a [[Seq]] of [[Row]]s. */ def checkAnswer(