Uses of Class
org.apache.flink.table.runtime.sequencedmultisetstate.SequencedMultiSetState.StateChangeInfo

Packages that use SequencedMultiSetState.StateChangeInfo

Package	Description
org.apache.flink.table.runtime.sequencedmultisetstate
org.apache.flink.table.runtime.sequencedmultisetstate.linked

Uses of SequencedMultiSetState.StateChangeInfo in org.apache.flink.table.runtime.sequencedmultisetstate

Methods in org.apache.flink.table.runtime.sequencedmultisetstate that return SequencedMultiSetState.StateChangeInfo

Modifier and Type	Method	Description
SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.add(T element, long timestamp)	Add the given element using the normal (non-multi) set semantics: if a matching element exists already, replace it (the timestamp is updated).
SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.append(T element, long timestamp)	Add the given element using the multi-set semantics, i.e. append.
static <T> SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.StateChangeInfo.forAddition(long sizeBefore, long sizeAfter)
static <T> SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.StateChangeInfo.forAllRemoved(long sizeBefore, long sizeAfter, T payload)
static <T> SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.StateChangeInfo.forRemovalNotFound(long size)
static <T> SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.StateChangeInfo.forRemovedLastAdded(long sizeBefore, long sizeAfter, T payload)
static <T> SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.StateChangeInfo.forRemovedOther(long sizeBefore, long sizeAfter)
SequencedMultiSetState.StateChangeInfo<T>	SequencedMultiSetState.remove(T element)	Remove the given element.

Uses of SequencedMultiSetState.StateChangeInfo in org.apache.flink.table.runtime.sequencedmultisetstate.linked

Methods in org.apache.flink.table.runtime.sequencedmultisetstate.linked that return SequencedMultiSetState.StateChangeInfo

Modifier and Type	Method	Description
SequencedMultiSetState.StateChangeInfo<org.apache.flink.table.data.RowData>	LinkedMultiSetState.add(org.apache.flink.table.data.RowData row, long timestamp)
SequencedMultiSetState.StateChangeInfo<org.apache.flink.table.data.RowData>	LinkedMultiSetState.append(org.apache.flink.table.data.RowData row, long timestamp)
SequencedMultiSetState.StateChangeInfo<org.apache.flink.table.data.RowData>	LinkedMultiSetState.remove(org.apache.flink.table.data.RowData row)