public class QueryableStoreTypes
extends java.lang.Object
QueryableStoreType
s provided with KafkaStreams. These
can be used with KafkaStreams.store(String, QueryableStoreType)
To access and query the StateStore
s that are part of a TopologyConstructor and Description |
---|
QueryableStoreTypes() |
Modifier and Type | Method and Description |
---|---|
static <K,V> QueryableStoreType<ReadOnlyKeyValueStore<K,V>> |
keyValueStore()
A
QueryableStoreType that accepts ReadOnlyKeyValueStore |
static <K,V> QueryableStoreType<ReadOnlySessionStore<K,V>> |
sessionStore()
A
QueryableStoreType that accepts ReadOnlySessionStore |
static <K,V> QueryableStoreType<ReadOnlyWindowStore<K,V>> |
windowStore()
A
QueryableStoreType that accepts ReadOnlyWindowStore |
public static <K,V> QueryableStoreType<ReadOnlyKeyValueStore<K,V>> keyValueStore()
QueryableStoreType
that accepts ReadOnlyKeyValueStore
K
- key type of the storeV
- value type of the storeKeyValueStoreType
public static <K,V> QueryableStoreType<ReadOnlyWindowStore<K,V>> windowStore()
QueryableStoreType
that accepts ReadOnlyWindowStore
K
- key type of the storeV
- value type of the storeWindowStoreType
public static <K,V> QueryableStoreType<ReadOnlySessionStore<K,V>> sessionStore()
QueryableStoreType
that accepts ReadOnlySessionStore
K
- key type of the storeV
- value type of the storeSessionStoreType