Fix Python test.

apache · Feb 10, 2015 · ae4649e · ae4649e
1 parent 609129c
commit ae4649e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py
@@ -184,7 +184,7 @@ def saveAsTable(self, tableName, source=None, mode="append", **options):
         if source is None:
             source = self.sql_ctx.getConf("spark.sql.sources.default",
                                           "org.apache.spark.sql.parquet")
-        jmode = _java_save_mode(mode)
+        jmode = self._java_save_mode(mode)
         joptions = MapConverter().convert(options,
                                           self.sql_ctx._sc._gateway._gateway_client)
         self._jdf.saveAsTable(tableName, source, jmode, joptions)
@@ -210,7 +210,7 @@ def save(self, path=None, source=None, mode="append", **options):
         if source is None:
             source = self.sql_ctx.getConf("spark.sql.sources.default",
                                           "org.apache.spark.sql.parquet")
-        jmode = _java_save_mode(mode)
+        jmode = self._java_save_mode(mode)
         joptions = MapConverter().convert(options,
                                           self._sc._gateway._gateway_client)
         self._jdf.save(source, jmode, joptions)