Package 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 Description StateChangeSet(UUID logId, SequenceNumber sequenceNumber, List<StateChange> changes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<StateChange>
getChanges()
UUID
getLogId()
SequenceNumber
getSequenceNumber()
long
getSize()
String
toString()
-
-
-
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()
-
-