[ https://issues.apache.org/jira/browse/BEAM-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784930#comment-16784930 ]
Pablo Estrada commented on BEAM-2857: ------------------------------------- The thing that has to be implemented are the `write` and `writeDynamic` transforms form `FileIO` that exist in the JAva SDK: https://beam.apache.org/releases/javadoc/2.11.0/org/apache/beam/sdk/io/FileIO.html#write-- > Create FileIO in Python > ----------------------- > > Key: BEAM-2857 > URL: https://issues.apache.org/jira/browse/BEAM-2857 > Project: Beam > Issue Type: New Feature > Components: sdk-py-core > Reporter: Eugene Kirpichov > Assignee: Pablo Estrada > Priority: Major > Labels: gsoc, gsoc2019, mentor, triaged > > Beam Java has a FileIO with operations: match()/matchAll(), readMatches(), > which together cover the majority of needs for general-purpose file > ingestion. Beam Python should have something similar. > An early design document for this: https://s.apache.org/fileio-beam-python -- This message was sent by Atlassian JIRA (v7.6.3#76005)