apache / apache/beam

[Feature Request][Go SDK]: Window Aware CombineFns

Open
#22,397 0 comments 0 reactions 0 assignees View on GitHub
go new feature P2
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

### What would you like to happen?

There's been a quiet request to have windows also be providable to CombineFn methods.

Very similar to key aware CombineFns in issue #22211 in that it would require expanding permitted parameter orderings for combine methods, and ensuring they are properly populated at execution time.

Combiners are already implicitly window aware, so there's no change in performance as a result of this.

For both issues, the generic `register.Combine` methods would need to be expanded accordingly to handling the additional parameters to the methods, when present.

Example use case is being able to have the accumulator extract time bounds information from the window, such as for hooking into OpenTelemetry metrics downstream.

### Issue Priority

Priority: 2

### Issue Component

Component: sdk-go

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.