Skip to content

Commit

Permalink
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions sdks/python/apache_beam/io/textio.py
Original file line number Diff line number Diff line change
@@ -871,6 +871,8 @@ def __init__(
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(

0 comments on commit 2a84a20

Please sign in to comment.