Package io.streamthoughts.azkarra.api.streams.rocksdb

Class DefaultRocksDBConfigSetter

java.lang.Object

io.streamthoughts.azkarra.api.streams.rocksdb.DefaultRocksDBConfigSetter

All Implemented Interfaces:

org.apache.kafka.streams.state.RocksDBConfigSetter

public class DefaultRocksDBConfigSetter
extends Object
implements org.apache.kafka.streams.state.RocksDBConfigSetter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultRocksDBConfigSetter.DefaultRocksDBConfigSetterConfig

Field Summary

Fields inherited from interface org.apache.kafka.streams.state.RocksDBConfigSetter

LOG

Constructor Summary

Constructors

Constructor	Description
DefaultRocksDBConfigSetter()

Method Summary

Modifier and Type	Method	Description
void	close(String storeName, org.rocksdb.Options options)
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

Constructor Detail

DefaultRocksDBConfigSetter

public DefaultRocksDBConfigSetter()

Method Detail

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