Class StateChange
- java.lang.Object
-
- org.apache.flink.runtime.state.changelog.StateChange
-
- All Implemented Interfaces:
Serializable
@Internal public class StateChange extends Object implements Serializable
Change of state of a keyed operator. Used for generic incremental checkpoints.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static int
META_KEY_GROUP
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]
getChange()
int
getKeyGroup()
static StateChange
ofDataChange(int keyGroup, byte[] change)
static StateChange
ofMetadataChange(byte[] change)
String
toString()
-
-
-
Field Detail
-
META_KEY_GROUP
public static final int META_KEY_GROUP
- See Also:
- Constant Field Values
-
-
Method Detail
-
ofMetadataChange
public static StateChange ofMetadataChange(byte[] change)
-
ofDataChange
public static StateChange ofDataChange(int keyGroup, byte[] change)
-
getKeyGroup
public int getKeyGroup()
-
getChange
public byte[] getChange()
-
-