org.apache.kafka.streams.state

Class BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers

java.lang.Object

org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers

All Implemented Interfaces:

org.apache.kafka.common.Configurable, DslStoreSuppliers

Enclosing class:

BuiltInDslStoreSuppliers

public static class BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers
extends Object
implements DslStoreSuppliers

A DslStoreSuppliers that supplies all stores backed by an in-memory map

Constructor Summary

Constructors

Constructor and Description
InMemoryDslStoreSuppliers()

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

InMemoryDslStoreSuppliers

public InMemoryDslStoreSuppliers()

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