Uses of Class org.apache.flink.state.forst.ForStDBWriteBatchWrapper (Flink : State backends : ForSt 2.0.2-cp1 API)

Packages that use ForStDBWriteBatchWrapper
Package Description

org.apache.flink.state.forst

org.apache.flink.state.forst.sync

Uses of ForStDBWriteBatchWrapper in org.apache.flink.state.forst

Methods in org.apache.flink.state.forst with parameters of type ForStDBWriteBatchWrapper
Modifier and Type	Method	Description
`void`	ForStDBBunchPutRequest.`process(ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.RocksDB db)`
`void`	ForStDBMultiRawMergePutRequest.`process(ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.RocksDB db)`
`void`	ForStDBPutRequest.`process(ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.RocksDB db)`

Uses of ForStDBWriteBatchWrapper in org.apache.flink.state.forst.sync

Constructors in org.apache.flink.state.forst.sync with parameters of type ForStDBWriteBatchWrapper
Constructor	Description
ForStSyncKeyedStateBackend(ClassLoader userCodeClassLoader, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.ExecutionConfig executionConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.forstdb.RocksDB db, LinkedHashMap<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, int keyGroupPrefixBytes, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.util.ResourceGuard forstResourceGuard, ForStSnapshotStrategyBase<K,?> checkpointSnapshotStrategy, ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.ColumnFamilyHandle defaultColumnFamilyHandle, ForStNativeMetricMonitor nativeMetricMonitor, org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder, org.apache.flink.runtime.state.PriorityQueueSetFactory priorityQueueFactory, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext, long writeBatchSize, CompletableFuture<Void> asyncCompactFuture)