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

Add support for MapValues

Details

    • Improvement
    • Status: Resolved
    • P3
    • Resolution: Duplicate
    • None
    • Not applicable
    • sdk-ideas
    • None

    Description

      Filed from: https://github.com/GoogleCloudPlatform/DataflowJavaSDK/issues/412

      Often I find myself needing to simply map a function over just the values of a key-valued PCollection. MapElements works for this, but suffers a small hit in readability (imho) and introduces some possibility for error.

      I wanted to see if there is any bandwidth / interest in adding this as a standard transform to the SDK. If so, I have attached a gist with a basic spike I have been using in my flows:

      https://gist.github.com/trentonstrong/8b60933dca545eb2138b72899195019e

      Attachments

        Issue Links

          Activity

            People

              jbonofre Jean-Baptiste Onofré
              lcwik Luke Cwik
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: