Uses of Class
org.apache.flink.runtime.state.StateHandleID

Packages that use StateHandleID

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.restore
org.apache.flink.contrib.streaming.state.snapshot
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.changelog.inmemory

Uses of StateHandleID in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return types with arguments of type StateHandleID

Modifier and Type	Method and Description
Map<StateHandleID,StreamStateHandle>	RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files, CheckpointStreamFactory checkpointStreamFactory, CheckpointedStateScope stateScope, CloseableRegistry closeableRegistry, CloseableRegistry tmpResourcesRegistry) Upload all the files to checkpoint fileSystem using specified number of threads.

Method parameters in org.apache.flink.contrib.streaming.state with type arguments of type StateHandleID

Modifier and Type	Method and Description
Map<StateHandleID,StreamStateHandle>	RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files, CheckpointStreamFactory checkpointStreamFactory, CheckpointedStateScope stateScope, CloseableRegistry closeableRegistry, CloseableRegistry tmpResourcesRegistry) Upload all the files to checkpoint fileSystem using specified number of threads.

Uses of StateHandleID in org.apache.flink.contrib.streaming.state.restore

Methods in org.apache.flink.contrib.streaming.state.restore that return types with arguments of type StateHandleID

Modifier and Type	Method and Description
SortedMap<Long,Map<StateHandleID,StreamStateHandle>>	RocksDBRestoreResult.getRestoredSstFiles()

Constructor parameters in org.apache.flink.contrib.streaming.state.restore with type arguments of type StateHandleID

Constructor and Description
RocksDBRestoreResult(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, long lastCompletedCheckpointId, UUID backendUID, SortedMap<Long,Map<StateHandleID,StreamStateHandle>> restoredSstFiles)

Uses of StateHandleID in org.apache.flink.contrib.streaming.state.snapshot

Constructor parameters in org.apache.flink.contrib.streaming.state.snapshot with type arguments of type StateHandleID

Constructor and Description

RocksIncrementalSnapshotStrategy(org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, TypeSerializer<K> keySerializer, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, LocalRecoveryConfig localRecoveryConfig, CloseableRegistry cancelStreamRegistry, File instanceBasePath, UUID backendUID, SortedMap<Long,Map<StateHandleID,StreamStateHandle>> uploadedStateHandles, RocksDBStateUploader rocksDBStateUploader, long lastCompletedCheckpointId)

Uses of StateHandleID in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return StateHandleID

Modifier and Type	Method and Description
StateHandleID	IncrementalRemoteKeyedStateHandle.getStateHandleId()
StateHandleID	DirectoryKeyedStateHandle.getStateHandleId()
StateHandleID	KeyedStateHandle.getStateHandleId() Returns a unique state handle id to distinguish with other keyed state handles.
StateHandleID	KeyGroupsStateHandle.getStateHandleId()
static StateHandleID	StateHandleID.randomStateHandleId()

Methods in org.apache.flink.runtime.state that return types with arguments of type StateHandleID

Modifier and Type	Method and Description
Map<StateHandleID,StreamStateHandle>	IncrementalRemoteKeyedStateHandle.getPrivateState()
Map<StateHandleID,StreamStateHandle>	IncrementalRemoteKeyedStateHandle.getSharedState()
Map<StateHandleID,StreamStateHandle>	IncrementalKeyedStateHandle.getSharedStateHandles() Returns a set of ids of all registered shared states in the backend at the time this was created.
Map<StateHandleID,StreamStateHandle>	IncrementalRemoteKeyedStateHandle.getSharedStateHandles()
Map<StateHandleID,StreamStateHandle>	IncrementalLocalKeyedStateHandle.getSharedStateHandles()

Methods in org.apache.flink.runtime.state with parameters of type StateHandleID

Modifier and Type	Method and Description
SharedStateRegistryKey	IncrementalRemoteKeyedStateHandle.createSharedStateRegistryKeyFromFileName(StateHandleID shId) Create a unique key to register one of our shared state handles.
static KeyGroupsStateHandle	KeyGroupsStateHandle.restore(KeyGroupRangeOffsets groupRangeOffsets, StreamStateHandle streamStateHandle, StateHandleID stateHandleId)
static IncrementalRemoteKeyedStateHandle	IncrementalRemoteKeyedStateHandle.restore(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)

Method parameters in org.apache.flink.runtime.state with type arguments of type StateHandleID

Modifier and Type	Method and Description
static IncrementalRemoteKeyedStateHandle	IncrementalRemoteKeyedStateHandle.restore(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)
static IncrementalRemoteKeyedStateHandle	IncrementalRemoteKeyedStateHandle.restore(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)

Constructors in org.apache.flink.runtime.state with parameters of type StateHandleID

Constructor and Description
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)
SharedStateRegistryKey(String prefix, StateHandleID stateHandleID)

Constructor parameters in org.apache.flink.runtime.state with type arguments of type StateHandleID

Constructor and Description
IncrementalLocalKeyedStateHandle(UUID backendIdentifier, long checkpointId, DirectoryStateHandle directoryStateHandle, KeyGroupRange keyGroupRange, StreamStateHandle metaDataState, Map<StateHandleID,StreamStateHandle> sharedStateHandleIDs)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)

Uses of StateHandleID in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return StateHandleID

Modifier and Type	Method and Description
StateHandleID	ChangelogStateHandleStreamImpl.getStateHandleId()
StateHandleID	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getStateHandleId()

Methods in org.apache.flink.runtime.state.changelog with parameters of type StateHandleID

Modifier and Type	Method and Description
static ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.restore(List<KeyedStateHandle> materialized, List<ChangelogStateHandle> nonMaterialized, KeyGroupRange keyGroupRange, long materializationID, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)
static ChangelogStateHandleStreamImpl	ChangelogStateHandleStreamImpl.restore(List<Tuple2<StreamStateHandle,Long>> handlesAndOffsets, KeyGroupRange keyGroupRange, long size, long incrementalSize, StateHandleID stateHandleID)

Uses of StateHandleID in org.apache.flink.runtime.state.changelog.inmemory

Methods in org.apache.flink.runtime.state.changelog.inmemory that return StateHandleID

Modifier and Type	Method and Description
StateHandleID	InMemoryChangelogStateHandle.getStateHandleId()

Methods in org.apache.flink.runtime.state.changelog.inmemory with parameters of type StateHandleID

Modifier and Type	Method and Description
static InMemoryChangelogStateHandle	InMemoryChangelogStateHandle.restore(List<StateChange> changes, SequenceNumber from, SequenceNumber to, KeyGroupRange keyGroupRange, StateHandleID stateHandleId)