Package org.apache.kafka.streams.state

package org.apache.kafka.streams.state

Provides interfaces for managing the intermediate state of a stateful streams application.

Related Packages

Package	Description
org.apache.kafka.streams	Provides the Kafka Streams library for building streaming data applications.
org.apache.kafka.streams.errors	Provides common exception classes for Streams applications.
org.apache.kafka.streams.kstream	Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input streams and tables.
org.apache.kafka.streams.processor	Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
org.apache.kafka.streams.query	Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
org.apache.kafka.streams.test	Provides classes for testing Kafka Streams applications with mocked inputs.

Class	Description
BuiltInDslStoreSuppliers	Collection of builtin DslStoreSuppliers for Kafka Streams.
BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers	A DslStoreSuppliers that supplies all stores backed by an in-memory map
BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers	A DslStoreSuppliers that supplies all stores backed by RocksDB
DslKeyValueParams	DslKeyValueParams is a wrapper class for all parameters that function as inputs to DslStoreSuppliers.keyValueStore(DslKeyValueParams).
DslSessionParams	DslSessionParams is a wrapper class for all parameters that function as inputs to DslStoreSuppliers.sessionStore(DslSessionParams).
DslStoreSuppliers	DslStoreSuppliers defines a grouping of factories to construct stores for each of the types of state store implementations in Kafka Streams.
DslWindowParams	DslWindowParams is a wrapper class for all parameters that function as inputs to DslStoreSuppliers.windowStore(DslWindowParams).
HostInfo	Represents a user defined endpoint in a KafkaStreams application.
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.
QueryableStoreTypes	Provides access to the QueryableStoreTypes provided with KafkaStreams.
QueryableStoreTypes.KeyValueStoreType<K,V>
QueryableStoreTypes.SessionStoreType<K,V>
QueryableStoreTypes.WindowStoreType<K,V>
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.
StateSerdes<K,V>	Factory for creating serializers / deserializers for state stores in Kafka Streams.
StoreBuilder<T extends StateStore>	Build a StateStore wrapped with optional caching and logging.
Stores	Factory for creating state stores in Kafka Streams.
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.
ValueAndTimestamp<V>	Combines a value from a KeyValue with a timestamp.
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.
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.
VersionedRecordIterator<V>	Iterator interface of VersionedRecord.
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.