Add insertInto and saveAsTable to Python API.

Author: Michael Armbrust <[email protected]> Closes apache#447 from marmbrus/pythonInsert and squashes the following commits: c7ab692 [Michael Armbrust] Keep docstrings < 72 chars. ff62870 [Michael Armbrust] Add insertInto and saveAsTable to Python API.
varunrao · Apr 19, 2014 · 10d0421 · 10d0421
1 parent 5d0f58b
commit 10d0421
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py
@@ -305,6 +305,19 @@ def registerAsTable(self, name):
         """
         self._jschema_rdd.registerAsTable(name)
 
+    def insertInto(self, tableName, overwrite = False):
+        """
+        Inserts the contents of this SchemaRDD into the specified table,
+        optionally overwriting any existing data.
+        """
+        self._jschema_rdd.insertInto(tableName, overwrite)
+
+    def saveAsTable(self, tableName):
+        """
+        Creates a new table with the contents of this SchemaRDD.
+        """
+        self._jschema_rdd.saveAsTable(tableName)
+
     def _toPython(self):
         # We have to import the Row class explicitly, so that the reference Pickler has is
         # pyspark.sql.Row instead of __main__.Row