kafka-streams-internals-RocksDBWindowStore.adoc

RocksDBWindowStore

RocksDBWindowStore is a custom WindowStore that uses the SegmentedBytesStore (as the underlying state store).

RocksDBWindowStore is created exclusively when RocksDbWindowBytesStoreSupplier is requested for a state store (and gives a RocksDBWindowStore with a RocksDBSegmentedBytesStore).

Creating RocksDBWindowStore Instance

RocksDBWindowStore takes the following when created:

• SegmentedBytesStore

• Serde<K> for keys

• Serde<V> for values

• retainDuplicates flag

• windowSize

RocksDBWindowStore initializes the internal registries and counters.

init Method

void init(final ProcessorContext context, final StateStore root)

Note	init is part of the StateStore Contract to initialize the state store.

init…​FIXME