[
https://issues.apache.org/jira/browse/BEAM-3707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Oliveira updated BEAM-3707:
----------------------------------
Description:
Get a portable version of non-lifted Combines working in Java.
Non-lifted combines should be done as an opaque ParDo after a GBK within a
Combine composite transform.
This task also requires implementing the anonymous case, where the ParDo and
GBK are not in a composite and the runner cannot identify the ParDo as a
Combine at all. For now this case only occurs when the Combine has side inputs.
was:
Get a portable version of non-lifted Combines working in Java.
Non-lifted combines should be done as an opaque ParDo after a GBK, created
SDK-side. Runners won't be able to identify it as a Combine, but it should work
without any changes to any runners.
> Implement portable non-lifted Combines in Java SDK
> --------------------------------------------------
>
> Key: BEAM-3707
> URL: https://issues.apache.org/jira/browse/BEAM-3707
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-java-core
> Reporter: Daniel Oliveira
> Assignee: Daniel Oliveira
> Priority: Major
> Labels: features, portability
>
> Get a portable version of non-lifted Combines working in Java.
> Non-lifted combines should be done as an opaque ParDo after a GBK within a
> Combine composite transform.
> This task also requires implementing the anonymous case, where the ParDo and
> GBK are not in a composite and the runner cannot identify the ParDo as a
> Combine at all. For now this case only occurs when the Combine has side
> inputs.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
