org.apache.flink.contrib.streaming.state

类 RocksDBResourceContainer

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBResourceContainer

所有已实现的接口:

AutoCloseable

public final class RocksDBResourceContainer
extends Object
implements AutoCloseable

The container for RocksDB resources, including predefined options, option factory and shared resource among instances.

This should be the only entrance for EmbeddedRocksDBStateBackend to get RocksDB options, and should be properly (and necessarily) closed to prevent resource leak.

构造器概要

构造器

构造器和说明
RocksDBResourceContainer()
RocksDBResourceContainer(PredefinedOptions predefinedOptions, RocksDBOptionsFactory optionsFactory)
RocksDBResourceContainer(PredefinedOptions predefinedOptions, RocksDBOptionsFactory optionsFactory, org.apache.flink.runtime.memory.OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources)
RocksDBResourceContainer(org.apache.flink.configuration.ReadableConfig configuration, PredefinedOptions predefinedOptions, RocksDBOptionsFactory optionsFactory, org.apache.flink.runtime.memory.OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources, boolean enableStatistics)

方法概要

限定符和类型	方法和说明
void	close()
org.rocksdb.ColumnFamilyOptions	getColumnOptions() Gets the RocksDB ColumnFamilyOptions to be used for all RocksDB instances.
org.rocksdb.DBOptions	getDbOptions() Gets the RocksDB DBOptions to be used for RocksDB instances.
org.rocksdb.ReadOptions	getReadOptions() Gets the RocksDB ReadOptions to be used for read operations.
Long	getWriteBufferManagerCapacity() Gets write buffer manager capacity.
org.rocksdb.WriteOptions	getWriteOptions() Gets the RocksDB WriteOptions to be used for write operations.

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

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

构造器详细资料

RocksDBResourceContainer

@VisibleForTesting
public RocksDBResourceContainer()

RocksDBResourceContainer

@VisibleForTesting
public RocksDBResourceContainer(PredefinedOptions predefinedOptions,
                                                   @Nullable
                                                   RocksDBOptionsFactory optionsFactory)

RocksDBResourceContainer

@VisibleForTesting
public RocksDBResourceContainer(PredefinedOptions predefinedOptions,
                                                   @Nullable
                                                   RocksDBOptionsFactory optionsFactory,
                                                   @Nullable
                                                   org.apache.flink.runtime.memory.OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources)

RocksDBResourceContainer

public RocksDBResourceContainer(org.apache.flink.configuration.ReadableConfig configuration,
                                PredefinedOptions predefinedOptions,
                                @Nullable
                                RocksDBOptionsFactory optionsFactory,
                                @Nullable
                                org.apache.flink.runtime.memory.OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources,
                                boolean enableStatistics)

方法详细资料

getDbOptions

public org.rocksdb.DBOptions getDbOptions()

Gets the RocksDB DBOptions to be used for RocksDB instances.

getWriteBufferManagerCapacity

public Long getWriteBufferManagerCapacity()

Gets write buffer manager capacity.

返回:

the capacity of the write buffer manager, or null if write buffer manager is not enabled.

getColumnOptions

public org.rocksdb.ColumnFamilyOptions getColumnOptions()

Gets the RocksDB ColumnFamilyOptions to be used for all RocksDB instances.

getWriteOptions

public org.rocksdb.WriteOptions getWriteOptions()

Gets the RocksDB WriteOptions to be used for write operations.

getReadOptions

public org.rocksdb.ReadOptions getReadOptions()

Gets the RocksDB ReadOptions to be used for read operations.

close

public void close()
           throws Exception

指定者:

close 在接口中 AutoCloseable

抛出:

Exception