kafka-streams-internals-TimeOrderedKeyValueBuffer.adoc

TimeOrderedKeyValueBuffer

TimeOrderedKeyValueBuffer is the extension of the StateStore contract for time-ordered key-value state stores that FIXME.

Table 1. TimeOrderedKeyValueBuffer Contract

Method	Description
bufferSize	long bufferSize() Used when…​FIXME
evictWhile	void evictWhile( Supplier<Boolean> predicate, Consumer<Eviction<K, V>> callback) Used when…​FIXME
minTimestamp	long minTimestamp() Used when…​FIXME
numRecords	int numRecords() Used when…​FIXME
priorValueForBuffered	Maybe<ValueAndTimestamp<V>> priorValueForBuffered(K key) Used when…​FIXME
put	void put( long time, K key, Change<V> value, ProcessorRecordContext recordContext) Used when…​FIXME
setSerdesIfNull	void setSerdesIfNull( Serde<K> keySerde, Serde<V> valueSerde) Used when…​FIXME

Note	InMemoryTimeOrderedKeyValueBuffer is the default and only known implementation of the TimeOrderedKeyValueBuffer Contract in Kafka Streams.