[
https://issues.apache.org/jira/browse/BEAM-833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Groh updated BEAM-833:
-
Description:
This primarily means calling the {{BoundedSource#splitAtFraction}} API during
the evaluation
[
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