org.apache.kafka.streams.state

Class QueryableStoreTypes

java.lang.Object

org.apache.kafka.streams.state.QueryableStoreTypes

public class QueryableStoreTypes
extends 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

Methods

Modifier and Type	Method and Description
static <K,V> QueryableStoreType<ReadOnlyKeyValueStore<K,V>>	keyValueStore() A QueryableStoreType that accepts ReadOnlyKeyValueStore
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:

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:

WindowStoreType