org.apache.flink.changelog.fs

Class StateChangeSet

java.lang.Object

org.apache.flink.changelog.fs.StateChangeSet

@ThreadSafe
 @Internal
public class StateChangeSet
extends Object

A set of changes made to some state(s) by a single state backend during a single checkpoint. There can be zero or more change sets for a single checkpoint. Thread-safe with the assumption that constructor arguments are not modified outside.

Constructor Summary

Constructors

Constructor and Description
StateChangeSet(UUID logId, SequenceNumber sequenceNumber, List<StateChange> changes)

Method Summary

Modifier and Type	Method and Description
List<StateChange>	getChanges()
UUID	getLogId()
SequenceNumber	getSequenceNumber()
long	getSize()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StateChangeSet

public StateChangeSet(UUID logId,
                      SequenceNumber sequenceNumber,
                      List<StateChange> changes)

Method Detail

getLogId

public UUID getLogId()

getSequenceNumber

public SequenceNumber getSequenceNumber()

getChanges

public List<StateChange> getChanges()

getSize

public long getSize()

toString

public String toString()

Overrides:

toString in class Object