See: Description
| Interface | Description |
|---|---|
| KeyValueBytesStoreSupplier |
A store supplier that can be used to create one or more
KeyValueStore<Bytes, byte[]> instances of type <Bytes, 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.
|
| 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<Byte, byte[]> instances. |
| 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. |
| TimestampedBytesStore | |
| TimestampedKeyValueStore<K,V> |
A key-(value/timestamp) store that supports put/get/delete and range queries.
|
| TimestampedWindowStore<K,V> |
Interface for storing the aggregated values of fixed-size time windows.
|
| WindowBytesStoreSupplier |
A store supplier that can be used to create one or more
WindowStore<Byte, byte[]> instances of type <Byte, byte[]>. |
| WindowStore<K,V> |
Interface for storing the aggregated values of fixed-size time windows.
|
| WindowStoreIterator<V> |
Iterator interface of
KeyValue with key typed Long used for WindowStore.fetch(Object, long, long)
and WindowStore.fetch(Object, Instant, Instant)
Users must call its close method explicitly upon completeness to release resources,
or use try-with-resources statement (available since JDK7) for this Closeable class. |
| Class | Description |
|---|---|
| HostInfo |
Represents a user defined endpoint in a
KafkaStreams application. |
| QueryableStoreTypes |
Provides access to the
QueryableStoreTypes provided with KafkaStreams. |
| QueryableStoreTypes.KeyValueStoreType<K,V> | |
| QueryableStoreTypes.SessionStoreType<K,V> | |
| QueryableStoreTypes.WindowStoreType<K,V> | |
| StateSerdes<K,V> |
Factory for creating serializers / deserializers for state stores in Kafka Streams.
|
| Stores |
Factory for creating state stores in Kafka Streams.
|
| StreamsMetadata | Deprecated
since 3.0.0 use
StreamsMetadata |
| ValueAndTimestamp<V> |
Combines a value from a
KeyValue with a timestamp. |