pyflink.datastream.state.ValueStateDescriptor#
- class ValueStateDescriptor(name: str, value_type_info: pyflink.common.typeinfo.TypeInformation)[source]#
StateDescriptor for ValueState. This can be used to create partitioned value state using RuntimeContext.get_state(ValueStateDescriptor).
Methods
enable_time_to_live
(ttl_config)Configures optional activation of state time-to-live (TTL).
get_name
()Get the name of the state.