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,
org.slf4j.Logger logger) |
static org.rocksdb.ColumnFamilyDescriptor |
createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager)
Creates a column descriptor for sate 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)
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)
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)
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, org.slf4j.Logger logger) throws IOException
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.