public class WindowStoreBuilder<K,V> extends AbstractStoreBuilder<K,V,WindowStore<K,V>>
name
Constructor and Description |
---|
WindowStoreBuilder(WindowBytesStoreSupplier storeSupplier,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valueSerde,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
WindowStore<K,V> |
build()
Build the store as defined by the builder.
|
long |
retentionPeriod() |
logConfig, loggingEnabled, name, withCachingDisabled, withCachingEnabled, withLoggingDisabled, withLoggingEnabled
public WindowStoreBuilder(WindowBytesStoreSupplier storeSupplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, org.apache.kafka.common.utils.Time time)
public WindowStore<K,V> build()
StoreBuilder
StateStore
public long retentionPeriod()