@@ -276,6 +276,7 @@ def save(self, path=None, format=None, mode=None, partitionBy=(), **options):
276276 * ``overwrite``: Overwrite existing data.
277277 * ``ignore``: Silently ignore this operation if data already exists.
278278 * ``error`` (default case): Throw an exception if data already exists.
279+ :param partitionBy: names of partitioning columns
279280 :param options: all other string options
280281
281282 >>> df.write.mode('append').parquet(os.path.join(tempfile.mkdtemp(), 'data'))
@@ -316,6 +317,7 @@ def saveAsTable(self, name, format=None, mode=None, partitionBy=(), **options):
316317 :param name: the table name
317318 :param format: the format used to save
318319 :param mode: one of `append`, `overwrite`, `error`, `ignore` (default: error)
320+ :param partitionBy: names of partitioning columns
319321 :param options: all other string options
320322 """
321323 self .partitionBy (partitionBy ).mode (mode ).options (** options )
@@ -350,7 +352,7 @@ def parquet(self, path, mode=None, partitionBy=()):
350352 * ``overwrite``: Overwrite existing data.
351353 * ``ignore``: Silently ignore this operation if data already exists.
352354 * ``error`` (default case): Throw an exception if data already exists.
353-
355+ :param partitionBy: names of partitioning columns
354356 >>> df.write.parquet(os.path.join(tempfile.mkdtemp(), 'data'))
355357 """
356358 self .partitionBy (partitionBy ).mode (mode )
0 commit comments