Package org.apache.kafka.streams.state

Class QueryableStoreTypes

java.lang.Object

org.apache.kafka.streams.state.QueryableStoreTypes

public class QueryableStoreTypes
extends java.lang.Object

Provides access to the QueryableStoreTypes provided with KafkaStreams. These can be used with KafkaStreams.store(String, QueryableStoreType) To access and query the StateStores that are part of a Topology

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<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 Detail

QueryableStoreTypes

public QueryableStoreTypes()

Method Detail

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

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

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