pyflink.datastream.state.MergingState

class MergingState(*args, **kwds)

Extension of AppendingState that allows merging of state. That is, two instance of MergingState can be combined into a single instance that contains all the information of the two merged states.

Methods

add(value)	Adding the given value to the tail of this list state.
clear()	Removes the value mapped under the current key.
get()	Returns the elements under the current key.