[
https://issues.apache.org/jira/browse/BEAM-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Oliveira updated BEAM-3124:
----------------------------------
Description: Some adjustments need to be made to the way flattens are
handled to the get them working for portability. Currently flattens are removed
from execution and the PCollections received by the flatten are instead sent to
the DoFns that consume the flatten. Ideally flattens should actually present in
the execution graphs to avoid having DoFns with multiple inputs, and they
should be able to execute on either the system runners or SDK runners when
appropriate. (was: Some adjustments need to be made to the way flattens are
handled to the get them working for portability. Flattens should present in the
execution graphs to avoid having DoFns with multiple inputs, and they should be
able to execute on either the system runners or SDK runners when appropriate.)
> Get flattens working with portability.
> --------------------------------------
>
> Key: BEAM-3124
> URL: https://issues.apache.org/jira/browse/BEAM-3124
> Project: Beam
> Issue Type: Improvement
> Components: beam-model
> Reporter: Daniel Oliveira
> Assignee: Daniel Oliveira
> Labels: portability
>
> Some adjustments need to be made to the way flattens are handled to the get
> them working for portability. Currently flattens are removed from execution
> and the PCollections received by the flatten are instead sent to the DoFns
> that consume the flatten. Ideally flattens should actually present in the
> execution graphs to avoid having DoFns with multiple inputs, and they should
> be able to execute on either the system runners or SDK runners when
> appropriate.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
