Class CompositeReadOnlySessionStore<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore<K,V>
-
- All Implemented Interfaces:
ReadOnlySessionStore<K,V>
public class CompositeReadOnlySessionStore<K,V> extends Object implements ReadOnlySessionStore<K,V>
Wrapper over the underlyingReadOnlySessionStore
s found in aProcessorTopology
-
-
Constructor Summary
Constructors Constructor Description CompositeReadOnlySessionStore(StateStoreProvider storeProvider, QueryableStoreType<ReadOnlySessionStore<K,V>> queryableStoreType, String storeName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
Constructor Detail
-
CompositeReadOnlySessionStore
public CompositeReadOnlySessionStore(StateStoreProvider storeProvider, QueryableStoreType<ReadOnlySessionStore<K,V>> queryableStoreType, String storeName)
-
-
Method Detail
-
fetch
public KeyValueIterator<Windowed<K>,V> fetch(K key)
Description copied from interface:ReadOnlySessionStore
Retrieve all aggregated sessions for the provided key. This iterator must be closed after use. For each key, the iterator guarantees ordering of sessions, starting from the oldest/earliest available session to the newest/latest session.- Specified by:
fetch
in interfaceReadOnlySessionStore<K,V>
- Parameters:
key
- record key to find aggregated session values for- Returns:
- KeyValueIterator containing all sessions for the provided key.
-
fetch
public KeyValueIterator<Windowed<K>,V> fetch(K from, K to)
Description copied from interface:ReadOnlySessionStore
Retrieve all aggregated sessions for the given range of keys. This iterator must be closed after use. For each key, the iterator guarantees ordering of sessions, starting from the oldest/earliest available session to the newest/latest session.- Specified by:
fetch
in interfaceReadOnlySessionStore<K,V>
- Parameters:
from
- first key in the range to find aggregated session values forto
- last key in the range to find aggregated session values for- Returns:
- KeyValueIterator containing all sessions for the provided key.
-
-