You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ri...@apache.org on 2024/02/27 14:27:33 UTC

(beam) branch master updated: [Python] Add doc comment for WriteToText.skip_if_empty (#30409)

This is an automated email from the ASF dual-hosted git repository.

riteshghorse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 2a84a20236b [Python] Add doc comment for WriteToText.skip_if_empty (#30409)
2a84a20236b is described below

commit 2a84a20236b6b6145cbd6e961ed0e1848c360100
Author: Ritesh Ghorse <ri...@gmail.com>
AuthorDate: Tue Feb 27 09:27:27 2024 -0500

    [Python] Add doc comment for WriteToText.skip_if_empty (#30409)
    
    * enable skip_if_empty
    
    * add doc comment
---
 sdks/python/apache_beam/io/textio.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sdks/python/apache_beam/io/textio.py b/sdks/python/apache_beam/io/textio.py
index 0e7ea8ff243..454fe4d69de 100644
--- a/sdks/python/apache_beam/io/textio.py
+++ b/sdks/python/apache_beam/io/textio.py
@@ -871,6 +871,8 @@ class WriteToText(PTransform):
         to exceed this value.  This also tracks the uncompressed,
         not compressed, size of the shard.
       skip_if_empty: Don't write any shards if the PCollection is empty.
+        In case of an empty PCollection, this will still delete existing
+        files having same file path and not create new ones.
     """
 
     self._sink = _TextSink(