kafka-streams-internals-InMemoryTimeOrderedKeyValueBuffer.adoc

InMemoryTimeOrderedKeyValueBuffer

InMemoryTimeOrderedKeyValueBuffer is a concrete TimeOrderedKeyValueBuffer that is created exclusively when KTableImpl is requested to suppress.

Creating InMemoryTimeOrderedKeyValueBuffer Instance

InMemoryTimeOrderedKeyValueBuffer takes the following to be created:

• Name of a state store

• loggingEnabled flag

• Serde<K> for keys

• Serde<V> for values

InMemoryTimeOrderedKeyValueBuffer initializes the internal properties.

build Method

InMemoryTimeOrderedKeyValueBuffer<K, V> build()

Note	build is part of the StoreBuilder Contract to create (build) a state store.

build simply creates a new InMemoryTimeOrderedKeyValueBuffer.