Modifier and Type | Method and Description |
---|---|
Map<StateHandleID,StreamStateHandle> |
RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files,
CheckpointStreamFactory checkpointStreamFactory,
CloseableRegistry closeableRegistry)
Upload all the files to checkpoint fileSystem using specified number of threads.
|
Modifier and Type | Method and Description |
---|---|
Map<StateHandleID,StreamStateHandle> |
RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files,
CheckpointStreamFactory checkpointStreamFactory,
CloseableRegistry closeableRegistry)
Upload all the files to checkpoint fileSystem using specified number of threads.
|
Modifier and Type | Method and Description |
---|---|
SortedMap<Long,Set<StateHandleID>> |
RocksDBRestoreResult.getRestoredSstFiles() |
Constructor and Description |
---|
RocksDBRestoreResult(org.rocksdb.RocksDB db,
org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle,
RocksDBNativeMetricMonitor nativeMetricMonitor,
long lastCompletedCheckpointId,
UUID backendUID,
SortedMap<Long,Set<StateHandleID>> restoredSstFiles) |
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,Set<StateHandleID>> materializedSstFiles,
RocksDBStateUploader rocksDBStateUploader,
long lastCompletedCheckpointId) |
Modifier and Type | Method and Description |
---|---|
Map<StateHandleID,StreamStateHandle> |
IncrementalRemoteKeyedStateHandle.getPrivateState() |
Map<StateHandleID,StreamStateHandle> |
IncrementalRemoteKeyedStateHandle.getSharedState() |
Set<StateHandleID> |
IncrementalRemoteKeyedStateHandle.getSharedStateHandleIDs() |
Set<StateHandleID> |
IncrementalKeyedStateHandle.getSharedStateHandleIDs()
Returns a set of ids of all registered shared states in the backend at the time this was
created.
|
Set<StateHandleID> |
IncrementalLocalKeyedStateHandle.getSharedStateHandleIDs() |
Modifier and Type | Method and Description |
---|---|
SharedStateRegistryKey |
IncrementalRemoteKeyedStateHandle.createSharedStateRegistryKeyFromFileName(StateHandleID shId)
Create a unique key to register one of our shared state handles.
|
Constructor and Description |
---|
SharedStateRegistryKey(String prefix,
StateHandleID stateHandleID) |
Constructor and Description |
---|
IncrementalLocalKeyedStateHandle(UUID backendIdentifier,
long checkpointId,
DirectoryStateHandle directoryStateHandle,
KeyGroupRange keyGroupRange,
StreamStateHandle metaDataState,
Set<StateHandleID> 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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.