org.apache.flink.contrib.streaming.state

Class RocksDBResourceContainer

java.lang.Object

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

All Implemented Interfaces:

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 RocksDBStateBackend to get RocksDB options, and should be properly (and necessarily) closed to prevent resource leak.

Constructor Summary

Constructors

Constructor and Description
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)

Method Summary

Modifier and Type	Method and Description
void	close()
org.rocksdb.DBOptions	getDbOptions() Gets the RocksDB DBOptions to be used for RocksDB instances.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBResourceContainer

public RocksDBResourceContainer()

RocksDBResourceContainer

public RocksDBResourceContainer(PredefinedOptions predefinedOptions,
                                @Nullable
                                RocksDBOptionsFactory optionsFactory)

RocksDBResourceContainer

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

Method Detail

getDbOptions

public org.rocksdb.DBOptions getDbOptions()

Gets the RocksDB DBOptions to be used for RocksDB instances.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception