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 the
QueryableStoreType
s provided with KafkaStreams
.
These can be used with KafkaStreams.store(StoreQueryParameters)
.
To access and query the StateStore
s that are part of a Topology
.-
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
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
.
-
Constructor Details
-
QueryableStoreTypes
public QueryableStoreTypes()
-
-
Method Details
-
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
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
AQueryableStoreType
that acceptsReadOnlySessionStore
.- Type Parameters:
K
- key type of the storeV
- value type of the store- Returns:
QueryableStoreTypes.SessionStoreType
-