org.apache.kafka.streams.state

Class BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers

java.lang.Object

org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers

All Implemented Interfaces:

org.apache.kafka.common.Configurable, DslStoreSuppliers

Enclosing class:

BuiltInDslStoreSuppliers

public static class BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers
extends Object
implements DslStoreSuppliers

A DslStoreSuppliers that supplies all stores backed by RocksDB

Constructor Summary

Constructors

Constructor and Description
RocksDBDslStoreSuppliers()

Method Summary

Modifier and Type	Method and Description
KeyValueBytesStoreSupplier	keyValueStore(DslKeyValueParams params)
SessionBytesStoreSupplier	sessionStore(DslSessionParams params)
WindowBytesStoreSupplier	windowStore(DslWindowParams params)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.streams.state.DslStoreSuppliers

configure

Constructor Detail

RocksDBDslStoreSuppliers

public RocksDBDslStoreSuppliers()

Method Detail

keyValueStore

public KeyValueBytesStoreSupplier keyValueStore(DslKeyValueParams params)

Specified by:

keyValueStore in interface DslStoreSuppliers

windowStore

public WindowBytesStoreSupplier windowStore(DslWindowParams params)

Specified by:

windowStore in interface DslStoreSuppliers

sessionStore

public SessionBytesStoreSupplier sessionStore(DslSessionParams params)

Specified by:

sessionStore in interface DslStoreSuppliers