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 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 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()	A QueryableStoreType that accepts ReadOnlyKeyValueStore.
static <K, V> QueryableStoreType<ReadOnlySessionStore<K,V>>	sessionStore()	A QueryableStoreType that accepts ReadOnlySessionStore.
static <K, V> QueryableStoreType<ReadOnlyKeyValueStore<K,ValueAndTimestamp<V>>>	timestampedKeyValueStore()	A QueryableStoreType that accepts ReadOnlyKeyValueStore<K, ValueAndTimestamp>.
static <K, V> QueryableStoreType<ReadOnlyWindowStore<K,ValueAndTimestamp<V>>>	timestampedWindowStore()	A QueryableStoreType that accepts ReadOnlyWindowStore<K, ValueAndTimestamp>.
static <K, V> QueryableStoreType<ReadOnlyWindowStore<K,V>>	windowStore()	A QueryableStoreType that accepts ReadOnlyWindowStore.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryableStoreTypes

public QueryableStoreTypes()

Method Details

keyValueStore

public static <K,
V>
QueryableStoreType<ReadOnlyKeyValueStore<K,V>> keyValueStore()

A QueryableStoreType that accepts ReadOnlyKeyValueStore.

Type Parameters:

K - key type of the store

V - value type of the store

Returns:

QueryableStoreTypes.KeyValueStoreType

timestampedKeyValueStore

public static <K,
V>
QueryableStoreType<ReadOnlyKeyValueStore<K,ValueAndTimestamp<V>>> timestampedKeyValueStore()

A QueryableStoreType that accepts ReadOnlyKeyValueStore<K, ValueAndTimestamp>.

Type Parameters:

K - key type of the store

V - value type of the store

Returns:

QueryableStoreTypes.TimestampedKeyValueStoreType

windowStore

public static <K,
V>
QueryableStoreType<ReadOnlyWindowStore<K,V>> windowStore()

A QueryableStoreType that accepts ReadOnlyWindowStore.

Type Parameters:

K - key type of the store

V - value type of the store

Returns:

QueryableStoreTypes.WindowStoreType

timestampedWindowStore

public static <K,
V>
QueryableStoreType<ReadOnlyWindowStore<K,ValueAndTimestamp<V>>> timestampedWindowStore()

A QueryableStoreType that accepts ReadOnlyWindowStore<K, ValueAndTimestamp>.

Type Parameters:

K - key type of the store

V - value type of the store

Returns:

QueryableStoreTypes.TimestampedWindowStoreType

sessionStore

public static <K,
V>
QueryableStoreType<ReadOnlySessionStore<K,V>> sessionStore()

A QueryableStoreType that accepts ReadOnlySessionStore.

Type Parameters:

K - key type of the store

V - value type of the store

Returns:

QueryableStoreTypes.SessionStoreType