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(