pyflink.datastream.state.ReducingStateDescriptor

class ReducingStateDescriptor(name: str, reduce_function, type_info: TypeInformation)

StateDescriptor for ReducingState. This can be used to create partitioned reducing state using RuntimeContext.get_reducing_state(ReducingStateDescriptor).

Methods

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