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

Class SessionStoreBuilder<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

StoreBuilder<SessionStore<K,V>>

public class SessionStoreBuilder<K,V>
extends AbstractStoreBuilder<K,V,SessionStore<K,V>>

Field Summary

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

name

Constructor Summary

Constructors

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

Method Summary

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

SessionStoreBuilder

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

Method Detail

build

public SessionStore<K,V> build()

Description copied from interface: StoreBuilder

Build the store as defined by the builder.

Returns:

the built StateStore

retentionPeriod

public long retentionPeriod()