File tree Expand file tree Collapse file tree 2 files changed +10
-2
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 2 files changed +10
-2
lines changed Original file line number Diff line number Diff line change @@ -499,7 +499,7 @@ object SparkBuild extends Build {
499499 parallelExecution in Test := false ,
500500 libraryDependencies ++= Seq (
501501 " com.typesafe" %% " scalalogging-slf4j" % " 1.0.1" ,
502- " ch.epfl.lamp" %% " scala-records" % " 0.1 -SNAPSHOT"
502+ " ch.epfl.lamp" %% " scala-records" % " 0.2 -SNAPSHOT"
503503 )
504504 )
505505
Original file line number Diff line number Diff line change @@ -23,13 +23,18 @@ import org.apache.spark.sql.test.TestSQLContext
2323
2424case class Person (name : String , age : Int )
2525
26+ case class Car (owner : Person , model : String )
27+
2628class TypedSqlSuite extends FunSuite {
2729 import TestSQLContext ._
2830
2931 val people = sparkContext.parallelize(
3032 Person (" Michael" , 30 ) ::
3133 Person (" Bob" , 40 ) :: Nil )
3234
35+ val cars = sparkContext.parallelize(
36+ Car (Person (" Michael" , 30 ), " GrandAm" ) :: Nil )
37+
3338 test(" typed query" ) {
3439 val results = sql " SELECT name FROM $people WHERE age = 30 "
3540 assert(results.first().name == " Michael" )
@@ -41,7 +46,10 @@ class TypedSqlSuite extends FunSuite {
4146 assert(results.first().age == 30 )
4247 }
4348
44- ignore(" nested results" ) { }
49+ ignore(" nested results" ) {
50+ val results = sql " SELECT * FROM $cars"
51+ assert(results.first().owner.name === " Michael" )
52+ }
4553
4654 test(" join query" ) {
4755 val results = sql """ SELECT a.name FROM $people a JOIN $people b ON a.age = b.age """
You can’t perform that action at this time.
0 commit comments