org.apache.flink.contrib.streaming.state

Class RocksDBOperationUtils

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBOperationUtils

public class RocksDBOperationUtils
extends Object

Utils for RocksDB Operations.

Constructor Summary

Constructors

Constructor and Description
RocksDBOperationUtils()

Method Summary

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 jobMemoryConfig, Environment env, double memoryFraction, org.slf4j.Logger logger, RocksDBMemoryControllerUtils.RocksDBMemoryFactory rocksDBMemoryFactory)
static org.rocksdb.ColumnFamilyDescriptor	createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity) Creates a column descriptor for a state column family.
static org.rocksdb.ColumnFamilyOptions	createColumnFamilyOptions(Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, String stateName)
static RocksDBKeyedStateBackend.RocksDbKvStateInfo	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.
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDBOperationUtils

public RocksDBOperationUtils()

Method Detail

openDB

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

Throws:

IOException

getRocksIterator

public static RocksIteratorWrapper getRocksIterator(org.rocksdb.RocksDB db,
                                                    org.rocksdb.ColumnFamilyHandle columnFamilyHandle,
                                                    org.rocksdb.ReadOptions readOptions)

registerKvStateInformation

public static void registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
                                              RocksDBNativeMetricMonitor nativeMetricMonitor,
                                              String columnFamilyName,
                                              RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)

createStateInfo

public static RocksDBKeyedStateBackend.RocksDbKvStateInfo createStateInfo(RegisteredStateMetaInfoBase metaInfoBase,
                                                                          org.rocksdb.RocksDB db,
                                                                          Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                                                          @Nullable
                                                                          RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                                                          @Nullable
                                                                          Long writeBufferManagerCapacity)

Creates a state info from a new meta info to use with a k/v state.

Creates the column family for the state. Sets TTL compaction filter if ttlCompactFiltersManager is not null.

createColumnFamilyDescriptor

public static org.rocksdb.ColumnFamilyDescriptor createColumnFamilyDescriptor(RegisteredStateMetaInfoBase metaInfoBase,
                                                                              Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                                                              @Nullable
                                                                              RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
                                                                              @Nullable
                                                                              Long writeBufferManagerCapacity)

Creates a column descriptor for a state column family.

Sets TTL compaction filter if ttlCompactFiltersManager is not null.

createColumnFamilyOptions

public static org.rocksdb.ColumnFamilyOptions createColumnFamilyOptions(Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
                                                                        String stateName)

addColumnFamilyOptionsToCloseLater

public static void addColumnFamilyOptionsToCloseLater(List<org.rocksdb.ColumnFamilyOptions> columnFamilyOptions,
                                                      org.rocksdb.ColumnFamilyHandle columnFamilyHandle)

allocateSharedCachesIfConfigured

@Nullable
public static OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> allocateSharedCachesIfConfigured(RocksDBMemoryConfiguration jobMemoryConfig,
                                                                                                                                               Environment env,
                                                                                                                                               double memoryFraction,
                                                                                                                                               org.slf4j.Logger logger,
                                                                                                                                               RocksDBMemoryControllerUtils.RocksDBMemoryFactory rocksDBMemoryFactory)
                                                                                                                                        throws IOException

Throws:

IOException