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

Support transcoding for Flatten in Samza Runner

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-spark
    • None

    Description

      The Beam documentation mentions that Flatten does not require coders of all inputs to be of the same type, as long as the result type is the same. However, the current implementation in the Spark Runner requires all coders to match.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              kw2542 Ke Wu
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: