Class QueryableStoreTypes
java.lang.Object
org.apache.kafka.streams.state.QueryableStoreTypes
Provides access to the
QueryableStoreTypes provided with KafkaStreams. These can be used with KafkaStreams.store(StoreQueryParameters). To access and query the StateStores that are part of a Topology.Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classConstructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionstatic <K,V> QueryableStoreType <ReadOnlyKeyValueStore<K, V>> AQueryableStoreTypethat acceptsReadOnlyKeyValueStore.static <K,V> QueryableStoreType <ReadOnlySessionStore<K, V>> AQueryableStoreTypethat acceptsReadOnlySessionStore.static <K,V> QueryableStoreType <ReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>> AQueryableStoreTypethat acceptsReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>.static <K,V> QueryableStoreType <ReadOnlyWindowStore<K, ValueAndTimestamp<V>>> AQueryableStoreTypethat acceptsReadOnlyWindowStore<K, ValueAndTimestamp<V>>.static <K,V> QueryableStoreType <ReadOnlyWindowStore<K, V>> AQueryableStoreTypethat acceptsReadOnlyWindowStore.
Constructor Details
QueryableStoreTypes
public QueryableStoreTypes()
Method Details
keyValueStore
AQueryableStoreTypethat 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()AQueryableStoreTypethat acceptsReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>.- Type Parameters:
K- key type of the storeV- value type of the store- Returns:
QueryableStoreTypes.TimestampedKeyValueStoreType
windowStore
AQueryableStoreTypethat 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()AQueryableStoreTypethat acceptsReadOnlyWindowStore<K, ValueAndTimestamp<V>>.- Type Parameters:
K- key type of the storeV- value type of the store- Returns:
QueryableStoreTypes.TimestampedWindowStoreType
sessionStore
AQueryableStoreTypethat acceptsReadOnlySessionStore.- Type Parameters:
K- key type of the storeV- value type of the store- Returns:
QueryableStoreTypes.SessionStoreType