Skip to content

Commit

Permalink
Python doc.
Browse files Browse the repository at this point in the history
  • Loading branch information
yhuai committed Jun 22, 2015
1 parent 889eb25 commit d21290a
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion python/pyspark/sql/readwriter.py
Original file line number Diff line number Diff line change
Expand Up @@ -276,6 +276,7 @@ def save(self, path=None, format=None, mode=None, partitionBy=(), **options):
* ``overwrite``: Overwrite existing data.
* ``ignore``: Silently ignore this operation if data already exists.
* ``error`` (default case): Throw an exception if data already exists.
:param partitionBy: names of partitioning columns
:param options: all other string options
>>> df.write.mode('append').parquet(os.path.join(tempfile.mkdtemp(), 'data'))
Expand Down Expand Up @@ -316,6 +317,7 @@ def saveAsTable(self, name, format=None, mode=None, partitionBy=(), **options):
:param name: the table name
:param format: the format used to save
:param mode: one of `append`, `overwrite`, `error`, `ignore` (default: error)
:param partitionBy: names of partitioning columns
:param options: all other string options
"""
self.partitionBy(partitionBy).mode(mode).options(**options)
Expand Down Expand Up @@ -350,7 +352,7 @@ def parquet(self, path, mode=None, partitionBy=()):
* ``overwrite``: Overwrite existing data.
* ``ignore``: Silently ignore this operation if data already exists.
* ``error`` (default case): Throw an exception if data already exists.
:param partitionBy: names of partitioning columns
>>> df.write.parquet(os.path.join(tempfile.mkdtemp(), 'data'))
"""
self.partitionBy(partitionBy).mode(mode)
Expand Down

0 comments on commit d21290a

Please sign in to comment.