Uses of Class
org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath

Packages that use IncrementalKeyedStateHandle.HandleAndLocalPath

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

Uses of IncrementalKeyedStateHandle.HandleAndLocalPath in org.apache.flink.contrib.streaming.state

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

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

Uses of IncrementalKeyedStateHandle.HandleAndLocalPath in org.apache.flink.contrib.streaming.state.restore

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

Modifier and Type	Method and Description
SortedMap<Long,Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>>	RocksDBRestoreResult.getRestoredSstFiles()

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

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

Uses of IncrementalKeyedStateHandle.HandleAndLocalPath in org.apache.flink.contrib.streaming.state.snapshot

Method parameters in org.apache.flink.contrib.streaming.state.snapshot with type arguments of type IncrementalKeyedStateHandle.HandleAndLocalPath

Modifier and Type	Method and Description
protected Optional<KeyedStateHandle>	RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation.getLocalSnapshot(StreamStateHandle localStreamStateHandle, List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState)

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

Constructor and Description
PreviousSnapshot(Collection<IncrementalKeyedStateHandle.HandleAndLocalPath> confirmedSstFiles)
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,Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>> uploadedStateHandles, RocksDBStateUploader rocksDBStateUploader, long lastCompletedCheckpointId)

Uses of IncrementalKeyedStateHandle.HandleAndLocalPath in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return IncrementalKeyedStateHandle.HandleAndLocalPath

Modifier and Type	Method and Description
static IncrementalKeyedStateHandle.HandleAndLocalPath	IncrementalKeyedStateHandle.HandleAndLocalPath.of(StreamStateHandle handle, String localPath)

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

Modifier and Type	Method and Description
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	IncrementalRemoteKeyedStateHandle.getPrivateState()
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	IncrementalRemoteKeyedStateHandle.getSharedState()
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	IncrementalKeyedStateHandle.getSharedStateHandles() Returns a list of all shared states and the corresponding localPath in the backend at the time this was created.
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	IncrementalRemoteKeyedStateHandle.getSharedStateHandles()
List<IncrementalKeyedStateHandle.HandleAndLocalPath>	IncrementalLocalKeyedStateHandle.getSharedStateHandles()

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

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

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

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