Package org.apache.kafka.streams.state

Interface Summary

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<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.
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 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 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.
StreamsMetadata	Represents the state of an instance (process) in a KafkaStreams application.