diff --git a/docs/_plugins/include_example.rb b/docs/_plugins/include_example.rb
index f7485826a762d67788def2cc58a01131dfbd73fb..306888801df21148b0dc0609c4a383fe5dc48318 100644
--- a/docs/_plugins/include_example.rb
+++ b/docs/_plugins/include_example.rb
@@ -32,8 +32,18 @@ module Jekyll
@code_dir = File.join(site.source, config_dir)
clean_markup = @markup.strip
- @file = File.join(@code_dir, clean_markup)
- @lang = clean_markup.split('.').last
+
+ parts = clean_markup.strip.split(' ')
+ if parts.length > 1 then
+ @snippet_label = ':' + parts[0]
+ snippet_file = parts[1]
+ else
+ @snippet_label = ''
+ snippet_file = parts[0]
+ end
+
+ @file = File.join(@code_dir, snippet_file)
+ @lang = snippet_file.split('.').last
code = File.open(@file).read.encode("UTF-8")
code = select_lines(code)
@@ -41,7 +51,7 @@ module Jekyll
rendered_code = Pygments.highlight(code, :lexer => @lang)
hint = "<div><small>Find full example code at " \
- "\"examples/src/main/#{clean_markup}\" in the Spark repo.</small></div>"
+ "\"examples/src/main/#{snippet_file}\" in the Spark repo.</small></div>"
rendered_code + hint
end
@@ -66,13 +76,13 @@ module Jekyll
# Select the array of start labels from code.
startIndices = lines
.each_with_index
- .select { |l, i| l.include? "$example on$" }
+ .select { |l, i| l.include? "$example on#{@snippet_label}$" }
.map { |l, i| i }
# Select the array of end labels from code.
endIndices = lines
.each_with_index
- .select { |l, i| l.include? "$example off$" }
+ .select { |l, i| l.include? "$example off#{@snippet_label}$" }
.map { |l, i| i }
raise "Start indices amount is not equal to end indices amount, see #{@file}." \
@@ -92,7 +102,10 @@ module Jekyll
if start == endline
lastIndex = endline
range = Range.new(start + 1, endline - 1)
- result += trim_codeblock(lines[range]).join
+ trimmed = trim_codeblock(lines[range])
+ # Filter out possible example tags of overlapped labels.
+ taggs_filtered = trimmed.select { |l| !l.include? '$example ' }
+ result += taggs_filtered.join
result += "\n"
end
result
diff --git a/docs/sql-programming-guide.md b/docs/sql-programming-guide.md
index 6c6bc8db6a1ff73b3489331ade1aa28e1c85b6aa..68419e1331594dfd6b4022e553eaa6e9bb4e378e 100644
--- a/docs/sql-programming-guide.md
+++ b/docs/sql-programming-guide.md
@@ -63,52 +63,23 @@ Throughout this document, we will often refer to Scala/Java Datasets of `Row`s a
<div class="codetabs">
<div data-lang="scala" markdown="1">
-The entry point into all functionality in Spark is the [`SparkSession`](api/scala/index.html#org.apache.spark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.build()`:
-
-{% highlight scala %}
-import org.apache.spark.sql.SparkSession
-
-val spark = SparkSession.build()
- .master("local")
- .appName("Word Count")
- .config("spark.some.config.option", "some-value")
- .getOrCreate()
-
-// this is used to implicitly convert an RDD to a DataFrame.
-import spark.implicits._
-{% endhighlight %}
+The entry point into all functionality in Spark is the [`SparkSession`](api/scala/index.html#org.apache.spark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.builder()`:
+{% include_example init_session scala/org/apache/spark/examples/sql/RDDRelation.scala %}
</div>
<div data-lang="java" markdown="1">
-The entry point into all functionality in Spark is the [`SparkSession`](api/java/index.html#org.apache.spark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.build()`:
+The entry point into all functionality in Spark is the [`SparkSession`](api/java/index.html#org.apache.spark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.builder()`:
-{% highlight java %}
-import org.apache.spark.sql.SparkSession
-
-SparkSession spark = SparkSession.build()
- .master("local")
- .appName("Word Count")
- .config("spark.some.config.option", "some-value")
- .getOrCreate();
-{% endhighlight %}
+{% include_example init_session java/org/apache/spark/examples/sql/JavaSparkSQL.java %}
</div>
<div data-lang="python" markdown="1">
-The entry point into all functionality in Spark is the [`SparkSession`](api/python/pyspark.sql.html#pyspark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.build`:
-
-{% highlight python %}
-from pyspark.sql import SparkSession
-
-spark = SparkSession.build \
- .master("local") \
- .appName("Word Count") \
- .config("spark.some.config.option", "some-value") \
- .getOrCreate()
-{% endhighlight %}
+The entry point into all functionality in Spark is the [`SparkSession`](api/python/pyspark.sql.html#pyspark.sql.SparkSession) class. To create a basic `SparkSession`, just use `SparkSession.builder`:
+{% include_example init_session python/sql.py %}
</div>
<div data-lang="r" markdown="1">
diff --git a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java
index e512979ac71b08037ac8e07362d5583ebfb5dec3..7fc6c007b6843f175856190a55325ad4401001db 100644
--- a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java
+++ b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java
@@ -26,7 +26,9 @@ import org.apache.spark.api.java.function.Function;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
+// $example on:init_session$
import org.apache.spark.sql.SparkSession;
+// $example off:init_session$
public class JavaSparkSQL {
public static class Person implements Serializable {
@@ -51,10 +53,13 @@ public class JavaSparkSQL {
}
public static void main(String[] args) throws Exception {
+ // $example on:init_session$
SparkSession spark = SparkSession
.builder()
.appName("JavaSparkSQL")
+ .config("spark.some.config.option", "some-value")
.getOrCreate();
+ // $example off:init_session$
System.out.println("=== Data source: RDD ===");
// Load a text file and convert each line to a Java Bean.
diff --git a/examples/src/main/python/sql.py b/examples/src/main/python/sql.py
index ac7246938d3b4edfbcf6fe33c8af0efa317dabb3..ea11d2c4c7b339c5154a7fa92c5b9ca6dfc87ab7 100644
--- a/examples/src/main/python/sql.py
+++ b/examples/src/main/python/sql.py
@@ -20,15 +20,20 @@ from __future__ import print_function
import os
import sys
+# $example on:init_session$
from pyspark.sql import SparkSession
+# $example off:init_session$
from pyspark.sql.types import Row, StructField, StructType, StringType, IntegerType
if __name__ == "__main__":
+ # $example on:init_session$
spark = SparkSession\
.builder\
.appName("PythonSQL")\
+ .config("spark.some.config.option", "some-value")\
.getOrCreate()
+ # $example off:init_session$
# A list of Rows. Infer schema from the first row, create a DataFrame and print the schema
rows = [Row(name="John", age=19), Row(name="Smith", age=23), Row(name="Sarah", age=18)]
diff --git a/examples/src/main/scala/org/apache/spark/examples/sql/RDDRelation.scala b/examples/src/main/scala/org/apache/spark/examples/sql/RDDRelation.scala
index 1b019fbb517710127e51d505490955116eb0fc97..deaa9f252b9b06a9d1a169307bea37984ff44f40 100644
--- a/examples/src/main/scala/org/apache/spark/examples/sql/RDDRelation.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/sql/RDDRelation.scala
@@ -18,7 +18,10 @@
// scalastyle:off println
package org.apache.spark.examples.sql
-import org.apache.spark.sql.{SaveMode, SparkSession}
+import org.apache.spark.sql.SaveMode
+// $example on:init_session$
+import org.apache.spark.sql.SparkSession
+// $example off:init_session$
// One method for defining the schema of an RDD is to make a case class with the desired column
// names and types.
@@ -26,13 +29,16 @@ case class Record(key: Int, value: String)
object RDDRelation {
def main(args: Array[String]) {
+ // $example on:init_session$
val spark = SparkSession
.builder
- .appName("RDDRelation")
+ .appName("Spark Examples")
+ .config("spark.some.config.option", "some-value")
.getOrCreate()
// Importing the SparkSession gives access to all the SQL functions and implicit conversions.
import spark.implicits._
+ // $example off:init_session$
val df = spark.createDataFrame((1 to 100).map(i => Record(i, s"val_$i")))
// Any RDD containing case classes can be used to create a temporary view. The schema of the