aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Armbrust <michael@databricks.com>2014-04-29 00:36:15 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-04-29 00:36:15 -0700
commit497be3ca2d8f0600e927f8f036177fcd3bb6e229 (patch)
treea19da2411f0feabdb0c8af48b3fef6b102b9b73f
parent719c8bc65e8a4096d09a6a9f15c90da3ddd7d9d4 (diff)
downloadspark-497be3ca2d8f0600e927f8f036177fcd3bb6e229.tar.gz
spark-497be3ca2d8f0600e927f8f036177fcd3bb6e229.tar.bz2
spark-497be3ca2d8f0600e927f8f036177fcd3bb6e229.zip
Minor fix to python table caching API.
Author: Michael Armbrust <michael@databricks.com> Closes #585 from marmbrus/pythonCacheTable and squashes the following commits: 7ec1f91 [Michael Armbrust] Minor fix to python table caching API.
-rw-r--r--python/pyspark/sql.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py
index 114fa138d0..1a62031db5 100644
--- a/python/pyspark/sql.py
+++ b/python/pyspark/sql.py
@@ -143,13 +143,13 @@ class SQLContext:
"""
return SchemaRDD(self._ssql_ctx.table(tableName), self)
- def cacheTable(tableName):
+ def cacheTable(self, tableName):
"""
Caches the specified table in-memory.
"""
self._ssql_ctx.cacheTable(tableName)
- def uncacheTable(tableName):
+ def uncacheTable(self, tableName):
"""
Removes the specified table from the in-memory cache.
"""