Package org.apache.kafka.streams.state
Class QueryableStoreTypes
- java.lang.Object
-
- org.apache.kafka.streams.state.QueryableStoreTypes
-
public class QueryableStoreTypes extends java.lang.Object
Provides access to theQueryableStoreType
s provided with KafkaStreams. These can be used withKafkaStreams.store(String, QueryableStoreType)
To access and query theStateStore
s that are part of a Topology
-
-
Constructor Summary
Constructors Constructor Description QueryableStoreTypes()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <K,V>
QueryableStoreType<ReadOnlyKeyValueStore<K,V>>keyValueStore()
AQueryableStoreType
that acceptsReadOnlyKeyValueStore
static <K,V>
QueryableStoreType<ReadOnlySessionStore<K,V>>sessionStore()
AQueryableStoreType
that acceptsReadOnlySessionStore
static <K,V>
QueryableStoreType<ReadOnlyWindowStore<K,V>>windowStore()
AQueryableStoreType
that acceptsReadOnlyWindowStore
-
-
-
Method Detail
-
keyValueStore
public static <K,V> QueryableStoreType<ReadOnlyKeyValueStore<K,V>> keyValueStore()
AQueryableStoreType
that acceptsReadOnlyKeyValueStore
- Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.KeyValueStoreType
-
windowStore
public static <K,V> QueryableStoreType<ReadOnlyWindowStore<K,V>> windowStore()
AQueryableStoreType
that acceptsReadOnlyWindowStore
- Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.WindowStoreType
-
sessionStore
public static <K,V> QueryableStoreType<ReadOnlySessionStore<K,V>> sessionStore()
AQueryableStoreType
that acceptsReadOnlySessionStore
- Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.SessionStoreType
-
-