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

Class TimestampedWindowStoreBuilder<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

StoreBuilder<TimestampedWindowStore<K,V>>

public class TimestampedWindowStoreBuilder<K,V>
extends AbstractStoreBuilder<K,ValueAndTimestamp<V>,TimestampedWindowStore<K,V>>

Field Summary

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

name

Constructor Summary

Constructors

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

Method Summary

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

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

TimestampedWindowStoreBuilder

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

Method Detail

build

public TimestampedWindowStore<K,V> build()

Description copied from interface: StoreBuilder

Build the store as defined by the builder.

Returns:

the built StateStore

retentionPeriod

public long retentionPeriod()