diff --git a/python/pyspark/sql/context.py b/python/pyspark/sql/context.py index a49c1b58d018075b8c35d610a54a5a14dc6099f5..b05aa2f5c4cd70811bd7c5623cce018e11b66414 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`.