Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.snapshot |
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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.