org.apache.kafka.streams.state

Class QueryableStoreTypes

java.lang.Object

org.apache.kafka.streams.state.QueryableStoreTypes

public final 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 and Description
QueryableStoreTypes()

Method Summary

Modifier and Type	Method and 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