You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Thomas Groh (JIRA)" <ji...@apache.org> on 2018/04/19 01:16:00 UTC

[jira] [Created] (BEAM-4135) Remove Use of Java SDK Types in the DirectRunner "engine"

Thomas Groh created BEAM-4135:
---------------------------------

             Summary: Remove Use of Java SDK Types in the DirectRunner "engine"
                 Key: BEAM-4135
                 URL: https://issues.apache.org/jira/browse/BEAM-4135
             Project: Beam
          Issue Type: New Feature
          Components: runner-direct
            Reporter: Thomas Groh
            Assignee: Thomas Groh


The "engine" consists of the components which determine where to schedule work and route it to the appropriate processors, such as WatermarkManager, DirectBundleProcessor, and associated.

 

These engine components never inspect the actual characteristics of the packaged work (e.g. the PCollection is a token, rather than a rich object), so they should not require use of a PCollection directly - instead, they can be generic.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)