Skip to content

Commit

Permalink
Remove experimental declarations from fileio.
Browse files Browse the repository at this point in the history
  • Loading branch information
robertwb committed Sep 29, 2020
1 parent bbda220 commit 69178e9
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions sdks/python/apache_beam/io/fileio.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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``.
Expand All @@ -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``.
Expand Down Expand Up @@ -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.
Expand All @@ -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
Expand All @@ -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.
"""
Expand Down

0 comments on commit 69178e9

Please sign in to comment.