Package io.streamthoughts.azkarra.commons.rocksdb

Class AzkarraRocksDBConfigSetter

java.lang.Object

io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter

All Implemented Interfaces:

org.apache.kafka.common.Configurable, org.apache.kafka.streams.state.RocksDBConfigSetter

public class AzkarraRocksDBConfigSetter
extends Object
implements org.apache.kafka.streams.state.RocksDBConfigSetter, org.apache.kafka.common.Configurable

This RocksDBConfigSetter implementation allows fine-tuning of RocksDB instances. It also allows to manage shared memory across all RocksDB instances and to enable dump of RocksDB statistics.

Field Summary

Fields

Modifier and Type	Field	Description
static long	ROCKSDB_BLOCK_CACHE_SIZE_DEFAULT

Constructor Summary

Constructors

Constructor	Description
AzkarraRocksDBConfigSetter()

Method Summary

Modifier and Type	Method	Description
void	close(String storeName, org.rocksdb.Options options)
void	configure(Map<String,?> configs)
void	setConfig(String storeName, org.rocksdb.Options options, Map<String,Object> configs)

Methods inherited from class java.lang.Object

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

Field Detail

ROCKSDB_BLOCK_CACHE_SIZE_DEFAULT

public static final long ROCKSDB_BLOCK_CACHE_SIZE_DEFAULT

See Also:

RocksDBStore, Constant Field Values

Constructor Detail

AzkarraRocksDBConfigSetter

public AzkarraRocksDBConfigSetter()

Method Detail

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

setConfig

public void setConfig(String storeName,
                      org.rocksdb.Options options,
                      Map<String,Object> configs)

Specified by:

setConfig in interface org.apache.kafka.streams.state.RocksDBConfigSetter

close

public void close(String storeName,
                  org.rocksdb.Options options)

Specified by:

close in interface org.apache.kafka.streams.state.RocksDBConfigSetter