Interface | Description |
---|---|
KeyValueBytesStoreSupplier |
A store supplier that can be used to create one or more
KeyValueStore instances of type <Byte, byte[]>. |
KeyValueIterator<K,V> |
Iterator interface of
KeyValue . |
KeyValueStore<K,V> |
A key-value store that supports put/get/delete and range queries.
|
QueryableStoreType<T> |
Used to enable querying of custom
StateStore types via the
KafkaStreams
API. |
ReadOnlyKeyValueStore<K,V> |
A key value store that only supports read operations.
|
ReadOnlySessionStore<K,AGG> |
A session store that only supports read operations.
|
ReadOnlyWindowStore<K,V> |
A window store that only supports read operations
Implementations should be thread-safe as concurrent reads and writes
are expected.
|
RocksDBConfigSetter |
An interface to that allows developers to customize the RocksDB settings
for a given Store.
|
SessionBytesStoreSupplier |
A store supplier that can be used to create one or more
SessionStore instances of type <Byte, byte[]>. |
SessionStore<K,AGG> |
Interface for storing the aggregated values of sessions
|
StoreBuilder<T extends StateStore> |
Build a
StateStore wrapped with optional caching and logging. |
StoreSupplier<T extends StateStore> |
A state store supplier which can create one or more
StateStore instances. |
WindowBytesStoreSupplier |
A store supplier that can be used to create one or more
WindowStore instances of type <Byte, byte[]>. |
WindowStore<K,V> |
A windowed store interface extending
StateStore . |
WindowStoreIterator<V> |
Iterator interface of
KeyValue with key typed Long used for ReadOnlyWindowStore.fetch(Object, long, long) . |
Class | Description |
---|---|
HostInfo |
Represents a user defined endpoint in a
KafkaStreams application. |
QueryableStoreTypes |
Provides access to the
QueryableStoreType s provided with KafkaStreams. |
StateSerdes<K,V> |
Factory for creating serializers / deserializers for state stores in Kafka Streams.
|
Stores |
Factory for creating state stores in Kafka Streams.
|
StreamsMetadata |
Represents the state of an instance (process) in a
KafkaStreams application. |