Package org.apache.kafka.streams.state

Interface Summary

Interface	Description
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.
SessionStore<K,AGG>	Interface for storing the aggregated values of sessions
Stores.InMemoryKeyValueFactory<K,V>	The interface used to create in-memory key-value stores.
Stores.KeyValueFactory<K,V>
Stores.PersistentKeyValueFactory<K,V>	The interface used to create off-heap key-value stores that use a local database.
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 Summary

Class	Description
HostInfo	Represents a user defined endpoint in a KafkaStreams application.
QueryableStoreTypes	Provides access to the QueryableStoreTypes 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.
Stores.StoreFactory
Stores.ValueFactory<K>	The factory for creating off-heap key-value stores.
StreamsMetadata	Represents the state of an instance (process) in a KafkaStreams application.