Package org.apache.kafka.streams.state

Class QueryableStoreTypes.WindowStoreType<K,V>

java.lang.Object

org.apache.kafka.streams.state.QueryableStoreTypes.WindowStoreType<K,V>

All Implemented Interfaces:

QueryableStoreType<ReadOnlyWindowStore<K,V>>

Enclosing class:

QueryableStoreTypes

public static class QueryableStoreTypes.WindowStoreType<K,V>
extends Object

Method Summary

Modifier and Type	Method	Description
boolean	accepts(StateStore stateStore)	Called when searching for StateStores to see if they match the type expected by implementors of this interface.
ReadOnlyWindowStore<K,V>	create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider, String storeName)	Create an instance of T (usually a facade) that developers can use to query the underlying StateStores.

Methods inherited from class java.lang.Object

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

Method Details

create

public ReadOnlyWindowStore<K,V> create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider,
 String storeName)

Description copied from interface: QueryableStoreType

Create an instance of T (usually a facade) that developers can use to query the underlying StateStores.

Parameters:

storeProvider - provides access to all the underlying StateStore instances

storeName - The name of the Store

Returns:

a read-only interface over a StateStore (cf. QueryableStoreTypes.KeyValueStoreType)

accepts

public boolean accepts(StateStore stateStore)

Description copied from interface: QueryableStoreType

Called when searching for StateStores to see if they match the type expected by implementors of this interface.

Specified by:

accepts in interface QueryableStoreType<T>

Parameters:

stateStore - The stateStore

Returns:

true if it is a match