org.apache.flink.contrib.streaming.state

类 RocksDBMemoryControllerUtils

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBMemoryControllerUtils

public class RocksDBMemoryControllerUtils
extends Object

Utils to create Cache and WriteBufferManager which are used to control total memory usage of RocksDB.

构造器概要

构造器

构造器和说明
RocksDBMemoryControllerUtils()

方法概要

限定符和类型	方法和说明
static org.apache.flink.contrib.streaming.state.RocksDBSharedResources	allocateRocksDBSharedResources(long totalMemorySize, double writeBufferRatio, double highPriorityPoolRatio, boolean usingPartitionedIndexFilters) Allocate memory controllable RocksDB shared resources.

从类继承的方法 java.lang.Object

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

构造器详细资料

RocksDBMemoryControllerUtils

public RocksDBMemoryControllerUtils()

方法详细资料

allocateRocksDBSharedResources

public static org.apache.flink.contrib.streaming.state.RocksDBSharedResources allocateRocksDBSharedResources(long totalMemorySize,
                                                                                                             double writeBufferRatio,
                                                                                                             double highPriorityPoolRatio,
                                                                                                             boolean usingPartitionedIndexFilters)

Allocate memory controllable RocksDB shared resources.

参数:

totalMemorySize - The total memory limit size.

writeBufferRatio - The ratio of total memory which is occupied by write buffer manager.

highPriorityPoolRatio - The high priority pool ratio of cache.

返回:

memory controllable RocksDB shared resources.