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 Weise (JIRA)" <ji...@apache.org> on 2016/10/26 16:29:59 UTC

[jira] [Updated] (BEAM-838) Support parallelism in Apex runner

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

Thomas Weise updated BEAM-838:
------------------------------
    Summary: Support parallelism in Apex runner  (was: Support parallalism in Apex runner)

> Support parallelism in Apex runner
> ----------------------------------
>
>                 Key: BEAM-838
>                 URL: https://issues.apache.org/jira/browse/BEAM-838
>             Project: Beam
>          Issue Type: Improvement
>          Components: runner-apex
>            Reporter: Thomas Weise
>
> The Apex runner should leverage the partitioning features of Apex for Beam pipeline translation (parallel partitions, dynamic partitioning and cascading unifiers etc.). Specifically for ParDo and GroupByKey (GBK partitioning will also need the appropriate stream codec that will partition the stream based on the encoded key). 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)