pyflink.datastream.state.AggregatingStateDescriptor#

class AggregatingStateDescriptor(name: str, agg_function, state_type_info)[source]#

A StateDescriptor for AggregatingState.

The type internally stored in the state is the type of the Accumulator of the AggregateFunction().

Methods

`enable_time_to_live`(ttl_config)	Configures optional activation of state time-to-live (TTL).
`get_agg_function`()
`get_name`()	Get the name of the state.