Package org.apache.kafka.streams.state.internals

Class KeyValueStoreBuilder<K,V>

java.lang.Object

org.apache.kafka.streams.state.internals.AbstractStoreBuilder<K,V,KeyValueStore<K,V>>

org.apache.kafka.streams.state.internals.KeyValueStoreBuilder<K,V>

All Implemented Interfaces:

StoreBuilder<KeyValueStore<K,V>>

public class KeyValueStoreBuilder<K,V>
extends AbstractStoreBuilder<K,V,KeyValueStore<K,V>>

Field Summary

Fields inherited from class org.apache.kafka.streams.state.internals.AbstractStoreBuilder

name

Constructor Summary

Constructors

Constructor	Description
KeyValueStoreBuilder(KeyValueBytesStoreSupplier storeSupplier, Serde<K> keySerde, Serde<V> valueSerde, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method	Description
KeyValueStore<K,V>	build()	Build the store as defined by the builder.

Methods inherited from class org.apache.kafka.streams.state.internals.AbstractStoreBuilder

logConfig, loggingEnabled, name, withCachingDisabled, withCachingEnabled, withLoggingDisabled, withLoggingEnabled

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyValueStoreBuilder

public KeyValueStoreBuilder(KeyValueBytesStoreSupplier storeSupplier,
                            Serde<K> keySerde,
                            Serde<V> valueSerde,
                            org.apache.kafka.common.utils.Time time)

Method Detail

build

public KeyValueStore<K,V> build()

Description copied from interface: StoreBuilder

Build the store as defined by the builder.

Returns:

the built StateStore