org.apache.flink.contrib.streaming.state

Interface RocksDBMemoryControllerUtils.RocksDBMemoryFactory

All Superinterfaces:

Serializable

Enclosing class:

RocksDBMemoryControllerUtils

public static interface RocksDBMemoryControllerUtils.RocksDBMemoryFactory
extends Serializable

Factory for Write Buffer Manager and Bock Cache.

Field Summary

Fields

Modifier and Type	Field and Description
static RocksDBMemoryControllerUtils.RocksDBMemoryFactory	DEFAULT

Method Summary

Modifier and Type	Method and Description
org.rocksdb.Cache	createCache(long cacheCapacity, double highPriorityPoolRatio)
org.rocksdb.WriteBufferManager	createWriteBufferManager(long writeBufferManagerCapacity, org.rocksdb.Cache cache)

Field Detail

DEFAULT

static final RocksDBMemoryControllerUtils.RocksDBMemoryFactory DEFAULT

Method Detail

createCache

org.rocksdb.Cache createCache(long cacheCapacity,
                              double highPriorityPoolRatio)

createWriteBufferManager

org.rocksdb.WriteBufferManager createWriteBufferManager(long writeBufferManagerCapacity,
                                                        org.rocksdb.Cache cache)