From d8220885c492141dfc61e8ffb92934f2339fe8d3 Mon Sep 17 00:00:00 2001
From: Jeff Zhang <zjffdu@apache.org>
Date: Thu, 26 Nov 2015 19:15:22 -0800
Subject: [PATCH] [SPARK-11917][PYSPARK] Add SQLContext#dropTempTable to
PySpark
Author: Jeff Zhang <zjffdu@apache.org>
Closes #9903 from zjffdu/SPARK-11917.
---
python/pyspark/sql/context.py | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/python/pyspark/sql/context.py b/python/pyspark/sql/context.py
index a49c1b58d0..b05aa2f5c4 100644
--- a/python/pyspark/sql/context.py
+++ b/python/pyspark/sql/context.py
@@ -445,6 +445,15 @@ class SQLContext(object):
else:
raise ValueError("Can only register DataFrame as table")
+ @since(1.6)
+ def dropTempTable(self, tableName):
+ """ Remove the temp table from catalog.
+
+ >>> sqlContext.registerDataFrameAsTable(df, "table1")
+ >>> sqlContext.dropTempTable("table1")
+ """
+ self._ssql_ctx.dropTempTable(tableName)
+
def parquetFile(self, *paths):
"""Loads a Parquet file, returning the result as a :class:`DataFrame`.
--
GitLab