aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/java')
-rw-r--r--examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java30
1 files changed, 28 insertions, 2 deletions
diff --git a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java
index cff9032f52..c5770d147a 100644
--- a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java
+++ b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java
@@ -54,6 +54,7 @@ import org.apache.spark.sql.types.DataTypes;
import org.apache.spark.sql.types.StructField;
import org.apache.spark.sql.types.StructType;
// $example off:programmatic_schema$
+import org.apache.spark.sql.AnalysisException;
// $example on:untyped_ops$
// col("...") is preferable to df.col("...")
@@ -84,7 +85,7 @@ public class JavaSparkSQLExample {
}
// $example off:create_ds$
- public static void main(String[] args) {
+ public static void main(String[] args) throws AnalysisException {
// $example on:init_session$
SparkSession spark = SparkSession
.builder()
@@ -101,7 +102,7 @@ public class JavaSparkSQLExample {
spark.stop();
}
- private static void runBasicDataFrameExample(SparkSession spark) {
+ private static void runBasicDataFrameExample(SparkSession spark) throws AnalysisException {
// $example on:create_df$
Dataset<Row> df = spark.read().json("examples/src/main/resources/people.json");
@@ -176,6 +177,31 @@ public class JavaSparkSQLExample {
// | 19| Justin|
// +----+-------+
// $example off:run_sql$
+
+ // $example on:global_temp_view$
+ // Register the DataFrame as a global temporary view
+ df.createGlobalTempView("people");
+
+ // Global temporary view is tied to a system preserved database `global_temp`
+ spark.sql("SELECT * FROM global_temp.people").show();
+ // +----+-------+
+ // | age| name|
+ // +----+-------+
+ // |null|Michael|
+ // | 30| Andy|
+ // | 19| Justin|
+ // +----+-------+
+
+ // Global temporary view is cross-session
+ spark.newSession().sql("SELECT * FROM global_temp.people").show();
+ // +----+-------+
+ // | age| name|
+ // +----+-------+
+ // |null|Michael|
+ // | 30| Andy|
+ // | 19| Justin|
+ // +----+-------+
+ // $example off:global_temp_view$
}
private static void runDatasetCreationExample(SparkSession spark) {