aboutsummaryrefslogtreecommitdiff
path: root/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala
diff options
context:
space:
mode:
Diffstat (limited to 'repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala')
-rw-r--r--repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala14
1 files changed, 7 insertions, 7 deletions
diff --git a/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala b/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala
index 99e1e1df33..4ce776e17d 100644
--- a/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala
+++ b/repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkILoopInit.scala
@@ -125,21 +125,21 @@ private[repl] trait SparkILoopInit {
command("""
@transient val sc = {
val _sc = org.apache.spark.repl.Main.interp.createSparkContext()
- println("Spark context available as sc " +
+ println("Spark context available as 'sc' " +
s"(master = ${_sc.master}, app id = ${_sc.applicationId}).")
_sc
}
""")
command("""
- @transient val sqlContext = {
- val _sqlContext = org.apache.spark.repl.Main.interp.createSQLContext()
- println("SQL context available as sqlContext.")
- _sqlContext
+ @transient val spark = {
+ val _session = org.apache.spark.repl.Main.interp.createSparkSession()
+ println("Spark session available as 'spark'.")
+ _session
}
""")
command("import org.apache.spark.SparkContext._")
- command("import sqlContext.implicits._")
- command("import sqlContext.sql")
+ command("import spark.implicits._")
+ command("import spark.sql")
command("import org.apache.spark.sql.functions._")
}
}