Package org.apache.flink.runtime.state

Interface CheckpointBoundKeyedStateHandle

All Superinterfaces:

CompositeStateHandle, KeyedStateHandle, Serializable, StateObject

All Known Subinterfaces:

ChangelogStateBackendHandle, IncrementalKeyedStateHandle

All Known Implementing Classes:

AbstractIncrementalStateHandle, ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl, ChangelogStateBackendLocalHandle, IncrementalLocalKeyedStateHandle, IncrementalRemoteKeyedStateHandle

public interface CheckpointBoundKeyedStateHandle
extends KeyedStateHandle

KeyedStateHandle that is bound to a specific checkpoint.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateObject

StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector

Method Summary

Modifier and Type	Method	Description
long	getCheckpointId()	Returns the ID of the checkpoint for which the handle was created or used.
CheckpointBoundKeyedStateHandle	rebound(long checkpointId)	Returns a new CheckpointBoundKeyedStateHandle Rebounding checkpoint id to a specific checkpoint id.

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

getCheckpointId

long getCheckpointId()

Returns the ID of the checkpoint for which the handle was created or used.

rebound

CheckpointBoundKeyedStateHandle rebound(long checkpointId)

Returns a new CheckpointBoundKeyedStateHandle Rebounding checkpoint id to a specific checkpoint id.

Parameters:

checkpointId - rebounded checkpoint id.