org.apache.kafka.streams.state

Class Stores

java.lang.Object

org.apache.kafka.streams.state.Stores

public class Stores
extends Object

Factory for creating state stores in Kafka Streams.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Stores.InMemoryKeyValueFactory<K,V> The interface used to create in-memory key-value stores.
static interface	Stores.KeyValueFactory<K,V> The interface used to specify the different kinds of key-value stores.
static interface	Stores.PersistentKeyValueFactory<K,V> The interface used to create off-heap key-value stores that use a local database.
static class	Stores.StoreFactory
static class	Stores.ValueFactory<K> The factory for creating off-heap key-value stores.

Constructor Summary

Constructors

Constructor and Description
Stores()

Method Summary

Methods

Modifier and Type	Method and Description
static Stores.StoreFactory	create(String name) Begin to create a new StateStoreSupplier instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

Stores

public Stores()

Method Detail

create

public static Stores.StoreFactory create(String name)

Begin to create a new StateStoreSupplier instance.

Parameters:

name - the name of the store

Returns:

the factory that can be used to specify other options or configurations for the store; never null