public interface TimeOrderedKeyValueBuffer extends StateStore
Modifier and Type | Method and 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) |
close, flush, init, isOpen, name, persistent
void evictWhile(java.util.function.Supplier<java.lang.Boolean> predicate, java.util.function.Consumer<KeyValue<org.apache.kafka.common.utils.Bytes,ContextualRecord>> callback)
void put(long time, org.apache.kafka.common.utils.Bytes key, ContextualRecord value)
int numRecords()
long bufferSize()
long minTimestamp()