[BEAM-310] Exercise splitIntoBundles/generateInitialSplits in the Direct Runner

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.3.0-incubating
• Component/s: runner-direct
• Assignee: Thomas Groh
• Reporter: Thomas Groh
• Created: 25/May/16 18:34
• Updated: 16/May/20 13:31
• Resolved: 28/Oct/16 17:22

Description

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

Issue Links

• is cloned by: BEAM-833 Exercise Dynamic Splitting in the DirectRunner
• links to: GitHub Pull Request #996
• links to: GitHub Pull Request #1019
• links to: GitHub Pull Request #1051
• links to: GitHub Pull Request #1063
• links to: GitHub Pull Request #1339