Package org.apache.kafka.streams.state
Class QueryableStoreTypes
- java.lang.Object
-
- org.apache.kafka.streams.state.QueryableStoreTypes
-
public final class QueryableStoreTypes extends Object
Provides access to theQueryableStoreType
s provided withKafkaStreams
. These can be used withKafkaStreams.store(StoreQueryParameters)
. To access and query theStateStore
s that are part of aTopology
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
QueryableStoreTypes.KeyValueStoreType<K,V>
static class
QueryableStoreTypes.SessionStoreType<K,V>
static class
QueryableStoreTypes.WindowStoreType<K,V>
-
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<ReadOnlyKeyValueStore<K,ValueAndTimestamp<V>>>timestampedKeyValueStore()
AQueryableStoreType
that acceptsReadOnlyKeyValueStore
.> static <K,V>
QueryableStoreType<ReadOnlyWindowStore<K,ValueAndTimestamp<V>>>timestampedWindowStore()
AQueryableStoreType
that acceptsReadOnlyWindowStore
.> 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
-
timestampedKeyValueStore
public static <K,V> QueryableStoreType<ReadOnlyKeyValueStore<K,ValueAndTimestamp<V>>> timestampedKeyValueStore()
AQueryableStoreType
that acceptsReadOnlyKeyValueStore
.> - Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.TimestampedKeyValueStoreType
-
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
-
timestampedWindowStore
public static <K,V> QueryableStoreType<ReadOnlyWindowStore<K,ValueAndTimestamp<V>>> timestampedWindowStore()
AQueryableStoreType
that acceptsReadOnlyWindowStore
.> - Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.TimestampedWindowStoreType
-
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
-
-