[BEAM-11103] [Go SDK] Native Streaming SplittableDoFns

• Type: New Feature
• Status: Resolved
• Priority: P3
• Resolution: Implemented
• Fix Version/s: 2.40.0
• Component/s: sdk-go
• Assignee: Unassigned
• Reporter: Robert Burke
• Created: 22/Oct/20 19:38
• Updated: 23/May/22 20:37
• Resolved: 20/May/22 13:22

Description

Basic SplittableDoFns enable scalable batch processing, currently exist in the Go SDK.

 

See Programing guide for more details on specific components (https://github.com/apache/beam/pull/13160)  (Update with actual link once that PR is merged pg site has been updated)

Issue Links

• links to: GitHub Pull Request #17723

Sub-Tasks

• [Go SDK] DoFn Self Checkpointing: Triage Needed
• [Go SDK] Watermark Estimation: Resolved
• [Go SDK] Truncating SDFs during drain: Triage Needed
• Enable Bundle Finalization in Go SDK: Resolved