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

Class TimestampedKeyValueStoreBuilder<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

StoreBuilder<TimestampedKeyValueStore<K,V>>

public class TimestampedKeyValueStoreBuilder<K,V>
extends AbstractStoreBuilder<K,ValueAndTimestamp<V>,TimestampedKeyValueStore<K,V>>

Field Summary

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

name

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
TimestampedKeyValueStore<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

TimestampedKeyValueStoreBuilder

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

Method Detail

build

public TimestampedKeyValueStore<K,V> build()

Description copied from interface: StoreBuilder

Build the store as defined by the builder.

Returns:

the built StateStore