diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py index d3d3a57fbf084..40292361ff90e 100644 --- a/sdks/python/apache_beam/io/fileio.py +++ b/sdks/python/apache_beam/io/fileio.py @@ -84,8 +84,6 @@ `destination` call is then passed to the `sink` call, to determine what sort of sink will be used for each destination. The return type of the `destination` parameter can be anything, as long as elements can be grouped by it. - -No backward compatibility guarantees. Everything in this module is experimental. """ # pytype: skip-file @@ -114,7 +112,6 @@ from apache_beam.options.value_provider import StaticValueProvider from apache_beam.options.value_provider import ValueProvider from apache_beam.transforms.window import GlobalWindow -from apache_beam.utils.annotations import experimental if TYPE_CHECKING: from apache_beam.transforms.window import BoundedWindow @@ -170,7 +167,6 @@ def process(self, file_pattern): return match_result.metadata_list -@experimental() class MatchFiles(beam.PTransform): """Matches a file pattern using ``FileSystems.match``. @@ -187,7 +183,6 @@ def expand(self, pcoll): return pcoll.pipeline | beam.Create([self._file_pattern]) | MatchAll() -@experimental() class MatchAll(beam.PTransform): """Matches file patterns from the input PCollection via ``FileSystems.match``. @@ -242,7 +237,6 @@ def read_utf8(self): return self.open().read().decode('utf-8') -@experimental() class ReadMatches(beam.PTransform): """Converts each result of MatchFiles() or MatchAll() to a ReadableFile. @@ -259,8 +253,6 @@ def expand(self, pcoll): class FileSink(object): """Specifies how to write elements to individual files in ``WriteToFiles``. - **NOTE: THIS CLASS IS EXPERIMENTAL.** - A Sink class must implement the following: - The ``open`` method, which initializes writing to a file handler (it is not @@ -286,8 +278,6 @@ def flush(self): class TextSink(FileSink): """A sink that encodes utf8 elements, and writes to file handlers. - **NOTE: THIS CLASS IS EXPERIMENTAL.** - This sink simply calls file_handler.write(record.encode('utf8') + '\n') on all records that come into it. """