Package org.apache.kafka.streams.state.internals

Interface TimeOrderedKeyValueBuffer<K,V>

All Superinterfaces:

StateStore

All Known Implementing Classes:

InMemoryTimeOrderedKeyValueBuffer

public interface TimeOrderedKeyValueBuffer<K,V>
extends StateStore

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	TimeOrderedKeyValueBuffer.Eviction<K,V>

Method Summary

Modifier and Type	Method	Description
long	bufferSize()
void	evictWhile(Supplier<Boolean> predicate, Consumer<TimeOrderedKeyValueBuffer.Eviction<K,V>> callback)
long	minTimestamp()
int	numRecords()
Maybe<ValueAndTimestamp<V>>	priorValueForBuffered(K key)
void	put(long time, K key, Change<V> value, ProcessorRecordContext recordContext)
void	setSerdesIfNull(Serde<K> keySerde, Serde<V> valueSerde)

Methods inherited from interface org.apache.kafka.streams.processor.StateStore

close, flush, init, isOpen, name, persistent

Method Detail

setSerdesIfNull

void setSerdesIfNull(Serde<K> keySerde,
                     Serde<V> valueSerde)

evictWhile

void evictWhile(Supplier<Boolean> predicate,
                Consumer<TimeOrderedKeyValueBuffer.Eviction<K,V>> callback)

priorValueForBuffered

Maybe<ValueAndTimestamp<V>> priorValueForBuffered(K key)

put

void put(long time,
         K key,
         Change<V> value,
         ProcessorRecordContext recordContext)

numRecords

int numRecords()

bufferSize

long bufferSize()

minTimestamp

long minTimestamp()