Hi everyone, I have a proposal of an approach we could take for the Go SDK WRT State and Timers, that might be of interest.
No changes are required to the FnAPI, as this is an SDK level proposal. Proposal w/ example: https://github.com/apache/beam/issues/25894 The short version is to enable users (or beam contributors) to produce better abstractions around state and timers, instead of requiring direct use of the primitives. Higher level components would permit easier re-use of common patterns that would otherwise require manual replication in a user's DoFn. This is current Go SDK specific, as we're finishing off being able have timer support there, and would require a small non-breaking change on how state is handled to enable. Please take a look, and let me know what you think (here or on the issue). Robert Burke Beam Go Busybody