Missing drop

zero323 · zero323 · commit 606f1e3a5f67 · 2017-05-11T22:11:51.000+02:00
diff --git a/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java b/examples/src/main/java/org/apache/spark/examples/sql/JavaSQLDataSourceExample.java
@@ -135,6 +135,7 @@ private static void runBasicDataSourceExample(SparkSession spark) {
     // $example off:write_partition_and_bucket$
 
     spark.sql("DROP TABLE IF EXISTS people_bucketed");
+    spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed");
   }
 
   private static void runBasicParquetExample(SparkSession spark) {
diff --git a/examples/src/main/python/sql/datasource.py b/examples/src/main/python/sql/datasource.py
@@ -48,8 +48,6 @@ def basic_datasource_example(spark):
         .saveAsTable("people_partitioned_bucketed"))
     # $example off:write_partition_and_bucket$
 
-    spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed")
-
     # $example on:manual_load_options$
     df = spark.read.load("examples/src/main/resources/people.json", format="json")
     df.select("name", "age").write.save("namesAndAges.parquet", format="parquet")
@@ -59,12 +57,12 @@ def basic_datasource_example(spark):
     df.write.bucketBy(42, "name").sortBy("age").saveAsTable("people_bucketed")
     # $example off:write_sorting_and_bucketing$
 
-    spark.sql("DROP TABLE IF EXISTS people_bucketed")
-
     # $example on:direct_sql$
     df = spark.sql("SELECT * FROM parquet.`examples/src/main/resources/users.parquet`")
     # $example off:direct_sql$
 
+    spark.sql("DROP TABLE IF EXISTS people_bucketed")
+    spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed")
 
 def parquet_example(spark):
     # $example on:basic_parquet_example$
diff --git a/examples/src/main/scala/org/apache/spark/examples/sql/SQLDataSourceExample.scala b/examples/src/main/scala/org/apache/spark/examples/sql/SQLDataSourceExample.scala
@@ -67,6 +67,7 @@ object SQLDataSourceExample {
     // $example off:write_partition_and_bucket$
 
     spark.sql("DROP TABLE IF EXISTS people_bucketed")
+    spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed")
   }
 
   private def runBasicParquetExample(spark: SparkSession): Unit = {

Original file line number	Diff line number	Diff line change
`@@ -135,6 +135,7 @@ private static void runBasicDataSourceExample(SparkSession spark) {`
`135`	`135`	`// $example off:write_partition_and_bucket$`
`136`	`136`
`137`	`137`	`spark.sql("DROP TABLE IF EXISTS people_bucketed");`
	`138`	`+ spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed");`
`138`	`139`	`}`
`139`	`140`
`140`	`141`	`private static void runBasicParquetExample(SparkSession spark) {`
Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ object SQLDataSourceExample {`
`67`	`67`	`// $example off:write_partition_and_bucket$`
`68`	`68`
`69`	`69`	`spark.sql("DROP TABLE IF EXISTS people_bucketed")`
	`70`	`+ spark.sql("DROP TABLE IF EXISTS people_partitioned_bucketed")`
`70`	`71`	`}`
`71`	`72`
`72`	`73`	`private def runBasicParquetExample(spark: SparkSession): Unit = {`