diff options
author | Michael Armbrust <michael@databricks.com> | 2014-08-02 18:27:04 -0700 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2014-08-02 18:27:04 -0700 |
commit | 1a8043739dc1d9435def6ea3c6341498ba52b708 (patch) | |
tree | fe499822fa58fc9416e8664b76839b4e198679a2 /python/pyspark | |
parent | d210022e96804e59e42ab902e53637e50884a9ab (diff) | |
download | spark-1a8043739dc1d9435def6ea3c6341498ba52b708.tar.gz spark-1a8043739dc1d9435def6ea3c6341498ba52b708.tar.bz2 spark-1a8043739dc1d9435def6ea3c6341498ba52b708.zip |
[SPARK-2739][SQL] Rename registerAsTable to registerTempTable
There have been user complaints that the difference between `registerAsTable` and `saveAsTable` is too subtle. This PR addresses this by renaming `registerAsTable` to `registerTempTable`, which more clearly reflects what is happening. `registerAsTable` remains, but will cause a deprecation warning.
Author: Michael Armbrust <michael@databricks.com>
Closes #1743 from marmbrus/registerTempTable and squashes the following commits:
d031348 [Michael Armbrust] Merge remote-tracking branch 'apache/master' into registerTempTable
4dff086 [Michael Armbrust] Fix .java files too
89a2f12 [Michael Armbrust] Merge remote-tracking branch 'apache/master' into registerTempTable
0b7b71e [Michael Armbrust] Rename registerAsTable to registerTempTable
Diffstat (limited to 'python/pyspark')
-rw-r--r-- | python/pyspark/sql.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py index 36e50e49c9..42b738e112 100644 --- a/python/pyspark/sql.py +++ b/python/pyspark/sql.py @@ -909,7 +909,7 @@ class SQLContext: ... b=True, list=[1, 2, 3], dict={"s": 0}, row=Row(a=1), ... time=datetime(2014, 8, 1, 14, 1, 5))]) >>> srdd = sqlCtx.inferSchema(allTypes) - >>> srdd.registerAsTable("allTypes") + >>> srdd.registerTempTable("allTypes") >>> sqlCtx.sql('select i+1, d+1, not b, list[1], dict["s"], time, row.a ' ... 'from allTypes where b and i > 0').collect() [Row(c0=2, c1=2.0, c2=False, c3=2, c4=0...8, 1, 14, 1, 5), a=1)] @@ -1486,19 +1486,23 @@ class SchemaRDD(RDD): """ self._jschema_rdd.saveAsParquetFile(path) - def registerAsTable(self, name): + def registerTempTable(self, name): """Registers this RDD as a temporary table using the given name. The lifetime of this temporary table is tied to the L{SQLContext} that was used to create this SchemaRDD. >>> srdd = sqlCtx.inferSchema(rdd) - >>> srdd.registerAsTable("test") + >>> srdd.registerTempTable("test") >>> srdd2 = sqlCtx.sql("select * from test") >>> sorted(srdd.collect()) == sorted(srdd2.collect()) True """ - self._jschema_rdd.registerAsTable(name) + self._jschema_rdd.registerTempTable(name) + + def registerAsTable(self, name): + warnings.warn("Use registerTempTable instead of registerAsTable.", DeprecationWarning) + self.registerTempTable(name) def insertInto(self, tableName, overwrite=False): """Inserts the contents of this SchemaRDD into the specified table. |