aboutsummaryrefslogtreecommitdiff
path: root/repl
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2015-03-09 13:29:19 -0700
committerReynold Xin <rxin@databricks.com>2015-03-09 13:29:19 -0700
commit70f88148bb04161a1a4968230d8e3fc7e3f8321a (patch)
treef62f785331fa8472990d3c98fbde9446025caa15 /repl
parentf7c799204358bcc38c5972a29e5994b78b25b515 (diff)
downloadspark-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')
-rw-r--r--repl/scala-2.11/src/test/scala/org/apache/spark/repl/ReplSuite.scala6
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)