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

Implement the limited set of portable primitives in the Java DirectRunner

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • Not applicable
    • runner-direct
    • None

    Description

      This is Flatten, Impulse, GroupByKeyOnly, GroupAlsoByWindow (for the implementation of the DirectRunner), and ExecutableStage

       

      Flatten and Impulse are straightforwards. GroupByKeyOnly requires extracting the runner-implementation of the PCollection's KeyCoder, and GroupAlsoByWindow and ExecutableStage both have specific concerns and are tracked independently

      Attachments

        Issue Links

          blocks

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-2899 Universal Local Runner

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          is blocked by

          Bug - A problem which impairs or prevents the functions of the product. BEAM-4073 The DirectRunner should interact with a Pipeline via an abstraction of the Graph rather than SDK types

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved

          Activity

            People

              tgroh Thomas Groh
              tgroh Thomas Groh
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: