pyflink.datastream.state.AggregatingStateDescriptor

class AggregatingStateDescriptor(name: str, agg_function, state_type_info)

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.