org.apache.kafka.streams.state

Interface Stores.PersistentKeyValueFactory<K,V>

Type Parameters:

K - the type of keys

V - the type of values

Enclosing class:

Stores

public static interface Stores.PersistentKeyValueFactory<K,V>

The interface used to create off-heap key-value stores that use a local database.

Method Summary

Methods

Modifier and Type	Method and Description
StateStoreSupplier	build() Return the instance of StateStoreSupplier of new key-value store.
Stores.PersistentKeyValueFactory<K,V>	windowed(long retentionPeriod, int numSegments, boolean retainDuplicates) Set the persistent store as a windowed key-value store

Method Detail

windowed

Stores.PersistentKeyValueFactory<K,V> windowed(long retentionPeriod,
                                             int numSegments,
                                             boolean retainDuplicates)

Set the persistent store as a windowed key-value store

Parameters:

retentionPeriod - the maximum period of time in milli-second to keep each window in this store

numSegments - the maximum number of segments for rolling the windowed store

retainDuplicates - whether or not to retain duplicate data within the window

build

StateStoreSupplier build()

Return the instance of StateStoreSupplier of new key-value store.

Returns:

the key-value store; never null