Expand description
Structures and traits for states added to streams.
Structs
The TimeVersionedState provides a default implementation of the State for a type S.
The structure automatically commits the final state for a timestamp into a HashMap and
initializes new states for a timestamp t by invoking their default method.
Traits
Trait that must be implemented by a state structure that is used in a Sequential operator.
This state structure must implement an append method that enables message callbacks to add
intermediate state to the structure, and a commit method that commits the final state for a
given timestamp t.