[ 
https://issues.apache.org/jira/browse/BEAM-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Henning Rohde resolved BEAM-3316.
---------------------------------
       Resolution: Fixed
    Fix Version/s: Not applicable

> Consider: do not use graph.Graph for runtime bundle representation
> ------------------------------------------------------------------
>
>                 Key: BEAM-3316
>                 URL: https://issues.apache.org/jira/browse/BEAM-3316
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-go
>            Reporter: Henning Rohde
>            Assignee: Henning Rohde
>            Priority: Minor
>             Fix For: Not applicable
>
>
> The internal graph.Graph representation is used to unify user pipeline and 
> the runtime subgraph. Perhaps we should instead translate the bundle 
> descriptors directly to an execution plan (=
>  []exec.Unit, but a encapsulating type seems useful). Aside: we would likely 
> also need to have them be re-usable across bundles serially.
> Such a change would keep the construction-time and runtime worlds more apart 
> instead of trying to unify them and we could remove DataSource/DataSink from 
> the graph. The direct runner would then only translate a graph.Graph to 
> []Unit and not have an awkward injection point for a DataManager.



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

Reply via email to