[BEAM-7692] Create a transform to assign an index when reading data from built in I/O transforms

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.13.0
• Component/s: io-ideas, io-java-text
• Labels: beam
• Assignee: Unassigned
• Reporter: SAILOKESH DIVI
• Created: 04/Jul/19 19:16
• Updated: 04/Jun/22 12:39

Description

As a beam user

when using any of the existing beams I/O transforms

I would like to add an index to each line read as part of the transform.

 

As spark has zipWithIndex to assign an index when reading files with the beam being abstraction layer for may runners. I would expect this feature should be added to beam