[MINOR] Update sample notebook with Spark 2.x APIs
diff --git a/etc/examples/notebooks/sqlcontext_sharing.ipynb b/etc/examples/notebooks/sqlcontext_sharing.ipynb
index be40dab..0b514d3 100644
--- a/etc/examples/notebooks/sqlcontext_sharing.ipynb
+++ b/etc/examples/notebooks/sqlcontext_sharing.ipynb
@@ -53,8 +53,8 @@
},
"outputs": [],
"source": [
- "val people = sqlContext.read.json(\"people.json\")\n",
- "people.registerTempTable(\"people\")\n",
+ "val people = spark.read.json(\"people.json\")\n",
+ "people.createOrReplaceTempView(\"people\")\n",
"people.show()"
]
},
@@ -74,7 +74,7 @@
"outputs": [],
"source": [
"%%PySpark\n",
- "people= sqlContext.table(\"people\")\n",
+ "people = spark.table(\"people\")\n",
"people.show()"
]
},
@@ -94,8 +94,8 @@
"outputs": [],
"source": [
"%%PySpark\n",
- "cars = sqlContext.read.json(\"cars.json\")\n",
- "cars.registerTempTable(\"cars\")\n",
+ "cars = spark.read.json(\"cars.json\")\n",
+ "cars.createOrReplaceTempView(\"cars\")\n",
"cars.show()"
]
},
@@ -114,7 +114,7 @@
},
"outputs": [],
"source": [
- "val cars = sqlContext.table(\"cars\")\n",
+ "val cars = spark.table(\"cars\")\n",
"cars.show()"
]
},
@@ -140,12 +140,14 @@
],
"metadata": {
"kernelspec": {
- "display_name": "Toree",
- "language": "",
- "name": "toree"
+ "display_name": "Apache Toree - Scala",
+ "language": "scala",
+ "name": "apache_toree_scala"
},
"language_info": {
- "name": "scala"
+ "file_extension": ".scala",
+ "name": "scala",
+ "version": "2.11.8"
}
},
"nbformat": 4,
