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. |
| VersionedBytesStore | A representation of a versioned key-value store as a KeyValueStore of type <Bytes, byte[]>. |
| VersionedBytesStoreSupplier | A store supplier that can be used to create one or more versioned key-value stores, specifically, VersionedBytesStore instances. |
| VersionedKeyValueStore<K,V> | A key-value store that stores multiple record versions per key, and supports timestamp-based retrieval operations to return the latest record (per key) as of a specified timestamp. |
| 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. |
| VersionedRecord<V> | Combines a value (from a key-value record) with a timestamp, for use as the return type from VersionedKeyValueStore.get(Object, long) and related methods. |