[BEAM-74] Testing harness for Unbounded Sources

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: sdk-java-core
• Labels: Clarified
• Assignee: Unassigned
• Reporter: Dan Halperin
• Created: 25/Feb/16 17:47
• Updated: 03/Jun/22 16:44

Description

SourceTestUtils has a fair bit of support for testing things like dynamic work rebalancing and initial splitting.

We should add variants that test UnboundedSource checkpoint-and-resume, etc.