pyflink.datastream.state.ValueState

class ValueState(*args, **kwds)

State interface for partitioned single-value state. The value can be retrieved or updated.

The state is accessed and modified by user functions, and checkpointed consistently by the system as part of the distributed snapshots.

Methods

clear()	Removes the value mapped under the current key.
update(value)	Updates the operator state accessible by value() to the given value.
value()	Returns the current value for the state.