Package org.apache.kafka.streams.state

Interface Summary

Interface	Description
KeyValueBytesStoreSupplier	A store supplier that can be used to create one or more KeyValueStore<Byte, byte[]> 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.
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 Summary

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	Represents the state of an instance (process) in a KafkaStreams application.
ValueAndTimestamp<V>	Combines a value from a KeyValue with a timestamp.