Uses of Class
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDbKvStateInfo

Packages that use RocksDBKeyedStateBackend.RocksDbKvStateInfo

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.contrib.streaming.state.sstmerge

Uses of RocksDBKeyedStateBackend.RocksDbKvStateInfo in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return RocksDBKeyedStateBackend.RocksDbKvStateInfo

Modifier and Type	Method and Description
static RocksDBKeyedStateBackend.RocksDbKvStateInfo	RocksDBOperationUtils.createStateInfo(RegisteredStateMetaInfoBase metaInfoBase, org.rocksdb.RocksDB db, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity) Creates a state info from a new meta info to use with a k/v state.

Methods in org.apache.flink.contrib.streaming.state with parameters of type RocksDBKeyedStateBackend.RocksDbKvStateInfo

Modifier and Type	Method and Description
static void	RocksDBOperationUtils.registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, RocksDBNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)

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

Modifier and Type	Method and Description
static void	RocksDBOperationUtils.registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, RocksDBNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)

Constructor parameters in org.apache.flink.contrib.streaming.state with type arguments of type RocksDBKeyedStateBackend.RocksDbKvStateInfo

Constructor and Description

RocksDBKeyedStateBackend(ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, org.rocksdb.RocksDB db, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, int keyGroupPrefixBytes, CloseableRegistry cancelStreamRegistry, StreamCompressionDecorator keyGroupCompressionDecorator, ResourceGuard rocksDBResourceGuard, RocksDBSnapshotStrategyBase<K,?> checkpointSnapshotStrategy, RocksDBWriteBatchWrapper writeBatchWrapper, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder, PriorityQueueSetFactory priorityQueueFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, InternalKeyContext<K> keyContext, long writeBatchSize, CompletableFuture<Void> asyncCompactFuture, RocksDBManualCompactionManager rocksDBManualCompactionManager)

Uses of RocksDBKeyedStateBackend.RocksDbKvStateInfo in org.apache.flink.contrib.streaming.state.restore

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

Constructor and Description
RocksDBFullRestoreOperation(KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)
RocksDBHeapTimersFullRestoreOperation(KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, HeapPriorityQueueSetFactory priorityQueueFactory, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)
RocksDBIncrementalRestoreOperation(String operatorIdentifier, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<IncrementalKeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean asyncCompactAfterRescale, boolean useDeleteFilesInRange, ExecutorService ioExecutor)
RocksDBNoneRestoreOperation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)

Uses of RocksDBKeyedStateBackend.RocksDbKvStateInfo in org.apache.flink.contrib.streaming.state.snapshot

Fields in org.apache.flink.contrib.streaming.state.snapshot with type parameters of type RocksDBKeyedStateBackend.RocksDbKvStateInfo

Modifier and Type	Field and Description
protected LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo>	RocksDBSnapshotStrategyBase.kvStateInformation Key/Value state meta info from the backend.

Method parameters in org.apache.flink.contrib.streaming.state.snapshot with type arguments of type RocksDBKeyedStateBackend.RocksDbKvStateInfo

Modifier and Type

Method and Description

static <K> RocksDBFullSnapshotResources<K>

RocksDBFullSnapshotResources.create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, KeyGroupRange keyGroupRange, TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, StreamCompressionDecorator keyGroupCompressionDecorator)

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

Constructor and Description
RocksDBFullSnapshotResources(ResourceGuard.Lease lease, org.rocksdb.Snapshot snapshot, List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy, List<HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots, org.rocksdb.RocksDB db, int keyGroupPrefixBytes, KeyGroupRange keyGroupRange, TypeSerializer<K> keySerializer, StreamCompressionDecorator streamCompressionDecorator)
RocksDBSnapshotStrategyBase(String description, org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, TypeSerializer<K> keySerializer, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, LocalRecoveryConfig localRecoveryConfig, File instanceBasePath, UUID backendUID)
RocksIncrementalSnapshotStrategy(org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, TypeSerializer<K> keySerializer, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, LocalRecoveryConfig localRecoveryConfig, File instanceBasePath, UUID backendUID, SortedMap<Long,Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>> uploadedStateHandles, RocksDBStateUploader rocksDBStateUploader, long lastCompletedCheckpointId)
RocksNativeFullSnapshotStrategy(org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, TypeSerializer<K> keySerializer, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, LocalRecoveryConfig localRecoveryConfig, File instanceBasePath, UUID backendUID, RocksDBStateUploader rocksDBStateUploader)

Uses of RocksDBKeyedStateBackend.RocksDbKvStateInfo in org.apache.flink.contrib.streaming.state.sstmerge

Methods in org.apache.flink.contrib.streaming.state.sstmerge with parameters of type RocksDBKeyedStateBackend.RocksDbKvStateInfo

Modifier and Type	Method and Description
void	RocksDBManualCompactionManager.register(RocksDBKeyedStateBackend.RocksDbKvStateInfo stateInfo)