Interface ChangelogStateBackendHandle
-
- All Superinterfaces:
CheckpointBoundKeyedStateHandle
,CompositeStateHandle
,KeyedStateHandle
,Serializable
,StateObject
- All Known Implementing Classes:
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl
,ChangelogStateBackendLocalHandle
@Internal public interface ChangelogStateBackendHandle extends KeyedStateHandle, CheckpointBoundKeyedStateHandle
A handle to ChangelogStateBackend state. Consists of the base and delta parts. Base part references materialized state (e.g. SST files), while delta part references state changes that were not not materialized at the time of the snapshot. Both are potentially empty lists as there can be no state or multiple states (e.g. after rescaling).
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl
-
Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateObject
StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
getMaterializationID()
List<KeyedStateHandle>
getMaterializedStateHandles()
List<ChangelogStateHandle>
getNonMaterializedStateHandles()
ChangelogStateBackendHandle
rebound(long checkpointId)
Returns a newCheckpointBoundKeyedStateHandle
Rebounding checkpoint id to a specific checkpoint id.-
Methods inherited from interface org.apache.flink.runtime.state.CheckpointBoundKeyedStateHandle
getCheckpointId
-
Methods inherited from interface org.apache.flink.runtime.state.CompositeStateHandle
getCheckpointedSize, registerSharedStates
-
Methods inherited from interface org.apache.flink.runtime.state.KeyedStateHandle
getIntersection, getKeyGroupRange, getStateHandleId
-
Methods inherited from interface org.apache.flink.runtime.state.StateObject
collectSizeStats, discardState, getStateSize
-
-
-
-
Method Detail
-
getMaterializedStateHandles
List<KeyedStateHandle> getMaterializedStateHandles()
-
getNonMaterializedStateHandles
List<ChangelogStateHandle> getNonMaterializedStateHandles()
-
getMaterializationID
long getMaterializationID()
-
rebound
ChangelogStateBackendHandle rebound(long checkpointId)
Description copied from interface:CheckpointBoundKeyedStateHandle
Returns a newCheckpointBoundKeyedStateHandle
Rebounding checkpoint id to a specific checkpoint id.- Specified by:
rebound
in interfaceCheckpointBoundKeyedStateHandle
- Parameters:
checkpointId
- rebounded checkpoint id.
-
-