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

Reply via email to