public class CompositeReadOnlySessionStore<K,V> extends java.lang.Object implements ReadOnlySessionStore<K,V>
ReadOnlySessionStore
s found in a ProcessorTopology
Constructor and Description |
---|
CompositeReadOnlySessionStore(StateStoreProvider storeProvider,
QueryableStoreType<ReadOnlySessionStore<K,V>> queryableStoreType,
java.lang.String storeName) |
Modifier and Type | Method and Description |
---|---|
KeyValueIterator<Windowed<K>,V> |
fetch(K key)
Retrieve all aggregated sessions for the provided key.
|
KeyValueIterator<Windowed<K>,V> |
fetch(K from,
K to)
Retrieve all aggregated sessions for the given range of keys.
|
public CompositeReadOnlySessionStore(StateStoreProvider storeProvider, QueryableStoreType<ReadOnlySessionStore<K,V>> queryableStoreType, java.lang.String storeName)
public KeyValueIterator<Windowed<K>,V> fetch(K key)
ReadOnlySessionStore
fetch
in interface ReadOnlySessionStore<K,V>
key
- record key to find aggregated session values forpublic KeyValueIterator<Windowed<K>,V> fetch(K from, K to)
ReadOnlySessionStore
fetch
in interface ReadOnlySessionStore<K,V>
from
- first key in the range to find aggregated session values forto
- last key in the range to find aggregated session values for