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

Class SequencedMultiSetState.StateChangeInfo<T>

java.lang.Object

org.apache.flink.table.runtime.sequencedmultisetstate.SequencedMultiSetState.StateChangeInfo<T>

Enclosing interface:

SequencedMultiSetState<T>

public static class SequencedMultiSetState.StateChangeInfo<T>
extends Object

Represents a result of a state changing operation.

Method Summary

Modifier and Type	Method	Description
static <T> SequencedMultiSetState.StateChangeInfo<T>	forAddition(long sizeBefore, long sizeAfter)
static <T> SequencedMultiSetState.StateChangeInfo<T>	forAllRemoved(long sizeBefore, long sizeAfter, T payload)
static <T> SequencedMultiSetState.StateChangeInfo<T>	forRemovalNotFound(long size)
static <T> SequencedMultiSetState.StateChangeInfo<T>	forRemovedLastAdded(long sizeBefore, long sizeAfter, T payload)
static <T> SequencedMultiSetState.StateChangeInfo<T>	forRemovedOther(long sizeBefore, long sizeAfter)
SequencedMultiSetState.StateChangeType	getChangeType()
Optional<T>	getPayload()	The payload depends on the SequencedMultiSetState.StateChangeType.
long	getSizeAfter()
boolean	wasEmpty()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

forAddition

public static <T> SequencedMultiSetState.StateChangeInfo<T> forAddition(long sizeBefore,
                                                                        long sizeAfter)

forRemovedLastAdded

public static <T> SequencedMultiSetState.StateChangeInfo<T> forRemovedLastAdded(long sizeBefore,
                                                                                long sizeAfter,
                                                                                T payload)

forRemovedOther

public static <T> SequencedMultiSetState.StateChangeInfo<T> forRemovedOther(long sizeBefore,
                                                                            long sizeAfter)

forAllRemoved

public static <T> SequencedMultiSetState.StateChangeInfo<T> forAllRemoved(long sizeBefore,
                                                                          long sizeAfter,
                                                                          T payload)

forRemovalNotFound

public static <T> SequencedMultiSetState.StateChangeInfo<T> forRemovalNotFound(long size)

getSizeAfter

public long getSizeAfter()

wasEmpty

public boolean wasEmpty()

getChangeType

public SequencedMultiSetState.StateChangeType getChangeType()

getPayload

public Optional<T> getPayload()

The payload depends on the SequencedMultiSetState.StateChangeType.