public class RocksDBOperationUtils extends Object
Constructor and Description |
---|
RocksDBOperationUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
addColumnFamilyOptionsToCloseLater(List<org.rocksdb.ColumnFamilyOptions> columnFamilyOptions,
org.rocksdb.ColumnFamilyHandle columnFamilyHandle) |
static OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> |
allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration memoryConfig,
MemoryManager memoryManager,
double memoryFraction,
org.slf4j.Logger logger) |
static org.rocksdb.ColumnFamilyDescriptor |
createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
Long writeBufferManagerCapacity)
Creates a column descriptor for a state column family.
|
static org.rocksdb.ColumnFamilyOptions |
createColumnFamilyOptions(java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
String stateName) |
static RocksDBKeyedStateBackend.RocksDbKvStateInfo |
createStateInfo(RegisteredStateMetaInfoBase metaInfoBase,
org.rocksdb.RocksDB db,
java.util.function.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.
|
static org.rocksdb.ReadOptions |
createTotalOrderSeekReadOptions()
Create a total order read option to avoid user misuse, see FLINK-17800 for more details.
|
static RocksIteratorWrapper |
getRocksIterator(org.rocksdb.RocksDB db,
org.rocksdb.ColumnFamilyHandle columnFamilyHandle,
org.rocksdb.ReadOptions readOptions) |
static org.rocksdb.RocksDB |
openDB(String path,
List<org.rocksdb.ColumnFamilyDescriptor> stateColumnFamilyDescriptors,
List<org.rocksdb.ColumnFamilyHandle> stateColumnFamilyHandles,
org.rocksdb.ColumnFamilyOptions columnFamilyOptions,
org.rocksdb.DBOptions dbOptions) |
static void |
registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
RocksDBNativeMetricMonitor nativeMetricMonitor,
String columnFamilyName,
RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn) |
public static org.rocksdb.RocksDB openDB(String path, List<org.rocksdb.ColumnFamilyDescriptor> stateColumnFamilyDescriptors, List<org.rocksdb.ColumnFamilyHandle> stateColumnFamilyHandles, org.rocksdb.ColumnFamilyOptions columnFamilyOptions, org.rocksdb.DBOptions dbOptions) throws IOException
IOException
public static RocksIteratorWrapper getRocksIterator(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle columnFamilyHandle, org.rocksdb.ReadOptions readOptions)
public static org.rocksdb.ReadOptions createTotalOrderSeekReadOptions()
Note, remember to close the generated ReadOptions
when dispose.
public static void registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, RocksDBNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)
public static RocksDBKeyedStateBackend.RocksDbKvStateInfo createStateInfo(RegisteredStateMetaInfoBase metaInfoBase, org.rocksdb.RocksDB db, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, @Nullable RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, @Nullable Long writeBufferManagerCapacity)
Creates the column family for the state. Sets TTL compaction filter if ttlCompactFiltersManager
is not null
.
public static org.rocksdb.ColumnFamilyDescriptor createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, @Nullable RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, @Nullable Long writeBufferManagerCapacity)
Sets TTL compaction filter if ttlCompactFiltersManager
is not null
.
public static org.rocksdb.ColumnFamilyOptions createColumnFamilyOptions(java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, String stateName)
public static void addColumnFamilyOptionsToCloseLater(List<org.rocksdb.ColumnFamilyOptions> columnFamilyOptions, org.rocksdb.ColumnFamilyHandle columnFamilyHandle)
@Nullable public static OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration memoryConfig, MemoryManager memoryManager, double memoryFraction, org.slf4j.Logger logger) throws IOException
IOException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.