[ https://issues.apache.org/jira/browse/BEAM-833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Groh updated BEAM-833: ----------------------------- Description: (was: BoundedSource#splitIntoBundles and UnboundedSource#generateInitialSplits are the methods by which sources can be accessed in parallel. Exercising these methods allows reads (and all transforms downstream) to be executed in parallel both pre and post a GroupByKey) > Exercise Dynamic Splitting in the DirectRunner > ---------------------------------------------- > > Key: BEAM-833 > URL: https://issues.apache.org/jira/browse/BEAM-833 > Project: Beam > Issue Type: Improvement > Components: runner-direct > Reporter: Thomas Groh > Assignee: Thomas Groh > -- This message was sent by Atlassian JIRA (v6.3.4#6332)