org.apache.flink.runtime.state

Interface IncrementalKeyedStateHandle

All Superinterfaces:

CheckpointBoundKeyedStateHandle, CompositeStateHandle, KeyedStateHandle, Serializable, StateObject

All Known Implementing Classes:

IncrementalLocalKeyedStateHandle, IncrementalRemoteKeyedStateHandle

public interface IncrementalKeyedStateHandle
extends KeyedStateHandle, CheckpointBoundKeyedStateHandle

Common interface to all incremental KeyedStateHandle.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IncrementalKeyedStateHandle.HandleAndLocalPath A Holder of StreamStateHandle and the corresponding localPath.

Method Summary

Modifier and Type	Method and Description
UUID	getBackendIdentifier() Returns the identifier of the state backend from which this handle was created.
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	getSharedStateHandles() Returns a list of all shared states and the corresponding localPath in the backend at the time this was created.

Methods inherited from interface org.apache.flink.runtime.state.CheckpointBoundKeyedStateHandle

getCheckpointId, rebound

Methods inherited from interface org.apache.flink.runtime.state.KeyedStateHandle

getIntersection, getKeyGroupRange, getStateHandleId

Methods inherited from interface org.apache.flink.runtime.state.CompositeStateHandle

getCheckpointedSize, registerSharedStates

Methods inherited from interface org.apache.flink.runtime.state.StateObject

discardState, getStateSize

Method Detail

getBackendIdentifier

@Nonnull
UUID getBackendIdentifier()

Returns the identifier of the state backend from which this handle was created.

getSharedStateHandles

@Nonnull
List<IncrementalKeyedStateHandle.HandleAndLocalPath> getSharedStateHandles()

Returns a list of all shared states and the corresponding localPath in the backend at the time this was created.