diff options
author | Reynold Xin <rxin@databricks.com> | 2015-03-09 13:29:19 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-03-09 13:29:19 -0700 |
commit | 70f88148bb04161a1a4968230d8e3fc7e3f8321a (patch) | |
tree | f62f785331fa8472990d3c98fbde9446025caa15 /repl/scala-2.11/src/test/scala/org/apache | |
parent | f7c799204358bcc38c5972a29e5994b78b25b515 (diff) | |
download | spark-70f88148bb04161a1a4968230d8e3fc7e3f8321a.tar.gz spark-70f88148bb04161a1a4968230d8e3fc7e3f8321a.tar.bz2 spark-70f88148bb04161a1a4968230d8e3fc7e3f8321a.zip |
[Docs] Replace references to SchemaRDD with DataFrame
Author: Reynold Xin <rxin@databricks.com>
Closes #4952 from rxin/schemardd-df-reference and squashes the following commits:
b2b1dbe [Reynold Xin] [Docs] Replace references to SchemaRDD with DataFrame
Diffstat (limited to 'repl/scala-2.11/src/test/scala/org/apache')
-rw-r--r-- | repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala b/repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala index f966f25c5a..ed9b207a86 100644 --- a/repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala +++ b/repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala @@ -263,14 +263,14 @@ class ReplSuite extends FunSuite { assertDoesNotContain("Exception", output) } - test("SPARK-2576 importing SQLContext.createSchemaRDD.") { + test("SPARK-2576 importing SQLContext.createDataFrame.") { // We need to use local-cluster to test this case. val output = runInterpreter("local-cluster[1,1,512]", """ |val sqlContext = new org.apache.spark.sql.SQLContext(sc) - |import sqlContext.createSchemaRDD + |import sqlContext.implicits._ |case class TestCaseClass(value: Int) - |sc.parallelize(1 to 10).map(x => TestCaseClass(x)).toSchemaRDD.collect + |sc.parallelize(1 to 10).map(x => TestCaseClass(x)).toDF.collect """.stripMargin) assertDoesNotContain("error:", output) assertDoesNotContain("Exception", output) |