Class ChangeLoggingTimestampedKeyValueBytesStore
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.WrappedStateStore<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>,byte[],byte[]>
-
- org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore
-
- org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedKeyValueBytesStore
-
- All Implemented Interfaces:
StateStore,CachedStateStore<byte[],byte[]>,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>,ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>
public class ChangeLoggingTimestampedKeyValueBytesStore extends ChangeLoggingKeyValueBytesStore
-
-
Method Summary
-
Methods inherited from class org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore
all, approximateNumEntries, delete, get, init, put, putAll, putIfAbsent, range
-
Methods inherited from class org.apache.kafka.streams.state.internals.WrappedStateStore
close, flush, isOpen, isTimestamped, name, persistent, setFlushListener, wrapped
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.streams.processor.StateStore
close, flush, isOpen, name, persistent
-
-