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.

results matching ""

    No results matching ""