[ https://issues.apache.org/jira/browse/BEAM-310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536420#comment-15536420 ]
ASF GitHub Bot commented on BEAM-310: ------------------------------------- Github user tgroh closed the pull request at: https://github.com/apache/incubator-beam/pull/996 > Exercise splitIntoBundles/generateInitialSplits in the Direct Runner > -------------------------------------------------------------------- > > Key: BEAM-310 > URL: https://issues.apache.org/jira/browse/BEAM-310 > Project: Beam > Issue Type: Improvement > Components: runner-direct > Reporter: Thomas Groh > Assignee: Thomas Groh > > 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 -- This message was sent by Atlassian JIRA (v6.3.4#6332)