Interface TimeOrderedKeyValueBuffer
-
- All Superinterfaces:
StateStore
- All Known Implementing Classes:
InMemoryTimeOrderedKeyValueBuffer
public interface TimeOrderedKeyValueBuffer extends StateStore
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
bufferSize()
void
evictWhile(java.util.function.Supplier<java.lang.Boolean> predicate, java.util.function.Consumer<KeyValue<org.apache.kafka.common.utils.Bytes,ContextualRecord>> callback)
long
minTimestamp()
int
numRecords()
void
put(long time, org.apache.kafka.common.utils.Bytes key, ContextualRecord value)
-
Methods inherited from interface org.apache.kafka.streams.processor.StateStore
close, flush, init, isOpen, name, persistent
-
-
-
-
Method Detail
-
evictWhile
void evictWhile(java.util.function.Supplier<java.lang.Boolean> predicate, java.util.function.Consumer<KeyValue<org.apache.kafka.common.utils.Bytes,ContextualRecord>> callback)
-
put
void put(long time, org.apache.kafka.common.utils.Bytes key, ContextualRecord value)
-
numRecords
int numRecords()
-
bufferSize
long bufferSize()
-
minTimestamp
long minTimestamp()
-
-