pyflink.datastream.state.ReducingStateDescriptor#
- class ReducingStateDescriptor(name: str, reduce_function, type_info: pyflink.common.typeinfo.TypeInformation)[source]#
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
()