K
- type of the record keysAGG
- type of the aggregated valuespublic interface SessionStore<K,AGG> extends StateStore, ReadOnlySessionStore<K,AGG>
Modifier and Type | Method and Description |
---|---|
KeyValueIterator<Windowed<K>,AGG> |
findSessions(K key,
long earliestSessionEndTime,
long latestSessionStartTime)
Fetch any sessions with the matching key and the sessions end is &le earliestEndTime and the sessions
start is &ge latestStartTime
|
void |
put(Windowed<K> sessionKey,
AGG aggregate)
Write the aggregated value for the provided key to the store
|
void |
remove(Windowed<K> sessionKey)
Remove the session aggregated with provided
Windowed key from the store |
close, flush, init, isOpen, name, persistent
fetch
KeyValueIterator<Windowed<K>,AGG> findSessions(K key, long earliestSessionEndTime, long latestSessionStartTime)
void remove(Windowed<K> sessionKey)
Windowed
key from the storesessionKey
- key of the session to remove