[BEAM-10246] FileIO.read + deleteOnCommit functionality

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: io-java-files
• Assignee: Unassigned
• Reporter: Pablo Estrada
• Created: 11/Jun/20 23:57
• Updated: 04/Jun/22 17:17

Description

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

 

FileIO.readMatches()

  .withDeleteAfterReading()

 

Something like this