Package org.apache.kafka.streams.state
package org.apache.kafka.streams.state
-
ClassDescriptionRepresents a user defined endpoint in a
KafkaStreamsapplication.A store supplier that can be used to create one or moreKeyValueStore<Bytes, byte[]>instances of type <Bytes, byte[]>.KeyValueIterator<K,V> Iterator interface ofKeyValue.KeyValueStore<K,V> A key-value store that supports put/get/delete and range queries.Used to enable querying of customStateStoretypes via theKafkaStreamsAPI.Provides access to theQueryableStoreTypes provided withKafkaStreams.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.An interface to that allows developers to customize the RocksDB settings for a given Store.A store supplier that can be used to create one or moreSessionStore<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 aStateStorewrapped with optional caching and logging.Factory for creating state stores in Kafka Streams.StoreSupplier<T extends StateStore>A state store supplier which can create one or moreStateStoreinstances.Deprecated.A key-(value/timestamp) store that supports put/get/delete and range queries.Interface for storing the aggregated values of fixed-size time windows.Combines a value from aKeyValuewith a timestamp.A store supplier that can be used to create one or moreWindowStore<Byte, byte[]>instances of type <Byte, byte[]>.WindowStore<K,V> Interface for storing the aggregated values of fixed-size time windows.Iterator interface ofKeyValuewith key typedLongused forWindowStore.fetch(Object, long, long)andWindowStore.fetch(Object, Instant, Instant)Users must call itsclosemethod explicitly upon completeness to release resources, or use try-with-resources statement (available since JDK7) for thisCloseableclass.
StreamsMetadata