[BEAM-4792] Add support for bounded SDF to all runners

• Type: New Feature
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.6.0
• Component/s: runner-core
• Assignee: Eugene Kirpichov
• Reporter: Eugene Kirpichov
• Created: 14/Jul/18 16:04
• Updated: 16/May/20 13:43
• Resolved: 09/Aug/18 22:13

Description

Executing bounded-per-element SDFs "naively" is pretty easy and doesn't require any special runner features, because it can be expanded into regular transforms. The naive implementation is sufficient for all runners except Dataflow, which has liquid sharding: support for that is a separate JIRA.

Issue Links

• contains: BEAM-3648 Support Splittable DoFn in Flink Batch Runner
• links to: GitHub Pull Request #5940