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 ""