spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject git commit: Minor fix to python table caching API.
Date Tue, 29 Apr 2014 07:36:37 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.0 4ed58aaa3 -> 0995787ac


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.
(cherry picked from commit 497be3ca2d8f0600e927f8f036177fcd3bb6e229)

Signed-off-by: Patrick Wendell <pwendell@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/0995787a
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/0995787a
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/0995787a

Branch: refs/heads/branch-1.0
Commit: 0995787ac6c71b7786ec68e3ee6f572ad7bf56a3
Parents: 4ed58aa
Author: Michael Armbrust <michael@databricks.com>
Authored: Tue Apr 29 00:36:15 2014 -0700
Committer: Patrick Wendell <pwendell@gmail.com>
Committed: Tue Apr 29 00:36:34 2014 -0700

----------------------------------------------------------------------
 python/pyspark/sql.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/0995787a/python/pyspark/sql.py
----------------------------------------------------------------------
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py
index 114fa13..1a62031 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.
         """


Mime
View raw message