[BEAM-10311] Sharing restriction trackers between SDF ProcessElement executor and DataSource

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: sdk-go
• Assignee: Daniel Oliveira
• Reporter: Daniel Oliveira
• Created: 23/Jun/20 23:07
• Updated: 08/Dec/20 01:48
• Resolved: 08/Dec/20 01:48

Description

Store trackers of elements currently processing in SDF, in a way accessible to other parts of the SDK harness (harness.go, plan.go, datasource.go, etc). This way when a split request comes in to the Plan, we can tell that there's an SDF processing an element and we're able to split within the element.

Issue Links

• links to: GitHub Pull Request #12095