jk-shah opened a new issue, #41310:
URL: https://github.com/apache/beam/issues/41310

   ### What would you like to happen?
   
   Add declarative `ttl=` configuration (processing-time or event-time 
expiration, update-on-write vs update-on-read-and-write, and visibility policy) 
and schema-evolution ergonomics to Beam `StateSpec` classes 
(`ReadModifyWriteStateSpec`, `BagStateSpec`, `SetStateSpec`, 
`CombiningValueStateSpec`, `OrderedListStateSpec`), plus runner portability 
support.
   
   ### Motivation
   Currently `apache_beam.transforms.userstate.StateSpec` only accepts `(name, 
coder)` with no built-in TTL. Spark 4.0+ `transformWithState` and Flink 
`StateTtlConfig` provide declarative per-key TTL and state schema evolution as 
first-class primitives, eliminating manual companion `TimerSpec` boilerplate 
and reducing OOM risk.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to