diff options
| author | Sean Zhong <seanzhong@databricks.com> | 2016-05-12 15:51:53 +0800 |
|---|---|---|
| committer | Cheng Lian <lian@databricks.com> | 2016-05-12 15:51:53 +0800 |
| commit | 33c6eb5218ce3c31cc9f632a67fd2c7057569683 (patch) | |
| tree | b8c84c24107bf1ece596450ef3a3eec26df1f21d /python/pyspark/sql/context.py | |
| parent | 5207a005cc86618907b8f467abc03eacef485ecd (diff) | |
| download | spark-33c6eb5218ce3c31cc9f632a67fd2c7057569683.tar.gz spark-33c6eb5218ce3c31cc9f632a67fd2c7057569683.tar.bz2 spark-33c6eb5218ce3c31cc9f632a67fd2c7057569683.zip | |
[SPARK-15171][SQL] Deprecate registerTempTable and add dataset.createTempView
## What changes were proposed in this pull request?
Deprecates registerTempTable and add dataset.createTempView, dataset.createOrReplaceTempView.
## How was this patch tested?
Unit tests.
Author: Sean Zhong <seanzhong@databricks.com>
Closes #12945 from clockfly/spark-15171.
Diffstat (limited to 'python/pyspark/sql/context.py')
| -rw-r--r-- | python/pyspark/sql/context.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/sql/context.py b/python/pyspark/sql/context.py index 02e742c124..ca111ae9bb 100644 --- a/python/pyspark/sql/context.py +++ b/python/pyspark/sql/context.py @@ -302,7 +302,7 @@ class SQLContext(object): >>> sqlContext.registerDataFrameAsTable(df, "table1") """ - self.sparkSession.catalog.registerTable(df, tableName) + df.createOrReplaceTempView(tableName) @since(1.6) def dropTempTable(self, tableName): @@ -311,7 +311,7 @@ class SQLContext(object): >>> sqlContext.registerDataFrameAsTable(df, "table1") >>> sqlContext.dropTempTable("table1") """ - self.sparkSession.catalog.dropTempTable(tableName) + self.sparkSession.catalog.dropTempView(tableName) @since(1.3) def createExternalTable(self, tableName, path=None, source=None, schema=None, **options): |