Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7692

Create a transform to assign an index when reading data from built in I/O transforms

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: P2
    • Resolution: Unresolved
    • Affects Version/s: 2.13.0
    • Fix Version/s: None
    • Component/s: io-ideas, io-java-text
    • Labels:

      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 

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              saidivi SAILOKESH DIVI
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: