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)
