Pablo Estrada created BEAM-10246:
------------------------------------

             Summary: FileIO.read + deleteOnCommit functionality
                 Key: BEAM-10246
                 URL: https://issues.apache.org/jira/browse/BEAM-10246
             Project: Beam
          Issue Type: Improvement
          Components: io-java-files
            Reporter: Pablo Estrada


A transforms that reads files, and deletes them once they've been consumed (and 
deals with retries appropriately).

 

FileIO.readMatches()

  .withDeleteAfterReading()

 

Something like this



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to